org.wso2.carbon.databridge.receiver.binary.internal
Class RequestProcessor

java.lang.Object
  org.wso2.carbon.databridge.receiver.binary.internal.RequestProcessor

public class RequestProcessor
extends Object

Constructor Summary

RequestProcessor(org.wso2.carbon.databridge.core.DataBridgeReceiverService dataBridgeReceiverService)

Method Summary

String	consume(String messageLine) Read the message and validate it, and put the string binary bundle to queue.
boolean	isMessageEnded()
String	processStream()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RequestProcessor

public RequestProcessor(org.wso2.carbon.databridge.core.DataBridgeReceiverService dataBridgeReceiverService)

Method Detail

consume

public String consume(String messageLine)
               throws Exception

Read the message and validate it, and put the string binary bundle to queue. and pass the event converter for binary message

Parameters:

messageLine - One line of binary message received.

Returns:

returns response that needs to be sent back to the client.

Throws:

Exception

isMessageEnded

public boolean isMessageEnded()

processStream

public String processStream()
                     throws Exception

Throws:

Exception