|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
public interface IMessageInput
Input Endpoint for a consumer to connect.
| Method Summary | |
|---|---|
List<IConsumer> |
getConsumers()
Getter for consumers list. |
IMessage |
pullMessage()
Pull message from this input endpoint. |
IMessage |
pullMessage(long wait)
Pull message from this input endpoint. |
void |
sendOOBControlMessage(IConsumer consumer,
OOBControlMessage oobCtrlMsg)
Send OOB Control Message to all providers on the other side of pipe. |
boolean |
subscribe(IConsumer consumer,
Map<?,?> paramMap)
Connect to a consumer. |
boolean |
unsubscribe(IConsumer consumer)
Disconnect from a consumer. |
| Method Detail |
|---|
IMessage pullMessage()
throws IOException
IOException - on errorIMessage pullMessage(long wait)
wait - milliseconds to wait when message is not
available.
boolean subscribe(IConsumer consumer,
Map<?,?> paramMap)
consumer - ConsumerparamMap - Parameters map
boolean unsubscribe(IConsumer consumer)
consumer - Consumer to disconnect
List<IConsumer> getConsumers()
void sendOOBControlMessage(IConsumer consumer,
OOBControlMessage oobCtrlMsg)
consumer - The consumer that sends the messageoobCtrlMsg - Out-of-band control message
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||