public class MessageControl extends java.lang.Object implements DataConsumer
Modifier and Type | Field and Description |
---|---|
boolean |
DEBUG |
Constructor and Description |
---|
MessageControl() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
data(byte[] b,
int len)
Incoming data from the transport.
|
int |
getDiscardDataDelay() |
BaseIOLog |
getIoLog() |
int |
getRetries() |
int |
getTimeout() |
TimeSource |
getTimeSource() |
void |
handleIOException(java.io.IOException e) |
IncomingResponseMessage |
send(OutgoingRequestMessage request) |
IncomingResponseMessage |
send(OutgoingRequestMessage request,
int timeout,
int retries) |
void |
send(OutgoingResponseMessage response) |
void |
setDiscardDataDelay(int discardDataDelay) |
void |
setExceptionHandler(MessagingExceptionHandler exceptionHandler) |
void |
setIoLog(BaseIOLog ioLog) |
void |
setRetries(int retries) |
void |
setTimeout(int timeout) |
void |
setTimeSource(TimeSource timeSource) |
void |
start(Transport transport,
MessageParser messageParser,
RequestHandler handler,
WaitingRoomKeyFactory waitingRoomKeyFactory) |
public void start(Transport transport, MessageParser messageParser, RequestHandler handler, WaitingRoomKeyFactory waitingRoomKeyFactory) throws java.io.IOException
java.io.IOException
public void close()
public void setExceptionHandler(MessagingExceptionHandler exceptionHandler)
public int getRetries()
public void setRetries(int retries)
public int getTimeout()
public void setTimeout(int timeout)
public int getDiscardDataDelay()
public void setDiscardDataDelay(int discardDataDelay)
public BaseIOLog getIoLog()
public void setIoLog(BaseIOLog ioLog)
public TimeSource getTimeSource()
public void setTimeSource(TimeSource timeSource)
public IncomingResponseMessage send(OutgoingRequestMessage request) throws java.io.IOException
java.io.IOException
public IncomingResponseMessage send(OutgoingRequestMessage request, int timeout, int retries) throws java.io.IOException
java.io.IOException
public void send(OutgoingResponseMessage response) throws java.io.IOException
java.io.IOException
public void data(byte[] b, int len)
data
in interface DataConsumer
b
- array of bytes representing the incoming informationlen
- length of the datapublic void handleIOException(java.io.IOException e)
handleIOException
in interface DataConsumer
Copyright © 2014 Infinite Automation Systems. All Rights Reserved.