public interface StreamingExchangeService
Interface to provide the following to Exchange
:
Modifier and Type | Method and Description |
---|---|
void |
connect()
Opens the connection to the upstream server for this instance.
|
int |
countEventsAvailable()
Returns number of events in consumer event queue.
|
void |
disconnect()
Closes the connection to the upstream server for this instance.
|
ExchangeEvent |
getNextEvent()
Returns next event in consumer event queue, then removes it.
|
org.java_websocket.WebSocket.READYSTATE |
getWebSocketStatus()
Returns current state of websocket connection.
|
void |
send(String msg)
Sends a msg over the socket.
|
void connect() throws Exception
Opens the connection to the upstream server for this instance.
Exception
void disconnect()
Closes the connection to the upstream server for this instance.
ExchangeEvent getNextEvent() throws InterruptedException
Returns next event in consumer event queue, then removes it.
InterruptedException
int countEventsAvailable()
Returns number of events in consumer event queue.
void send(String msg)
Sends a msg over the socket.
org.java_websocket.WebSocket.READYSTATE getWebSocketStatus()
Copyright © 2012–2016 Xeiam, LLC. All rights reserved.