Modifier and Type | Method and Description |
---|---|
Message |
MessageInputStream.readMessage()
Decodes the next message in the input stream if a message is found.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Message.equals(Message message) |
void |
MessageHandler.handleMessage(Message readMessage,
Context context,
Coder coder) |
void |
MessageBlockReader.messageRead(InputStream in,
Message message) |
void |
MessageBlockWriter.writeBlockLength(OutputStream out,
Message message,
byte[] encodedMessage) |
void |
MessageOutputStream.writeMessage(Message message) |
void |
MessageOutputStream.writeMessage(Message message,
boolean flush) |
Modifier and Type | Method and Description |
---|---|
Message |
FastDecoder.readMessage()
Read the next FAST message from the input stream.
|
Message |
FastDecoder.readMessage(int offset)
Helper method that can be used to read past a non-FAST message header.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
FastEncoder.encode(Message message)
WARNING: Not thread-safe.
|
Modifier and Type | Method and Description |
---|---|
static ErrorCode |
ErrorCode.getAlertCode(Message alertMsg) |
Modifier and Type | Method and Description |
---|---|
void |
FastMessageInterpreter.accept(Message message)
Accept each incoming message.
|
Modifier and Type | Method and Description |
---|---|
void |
ScpMessageProducer.onMessage(Session session,
Message message) |
Modifier and Type | Method and Description |
---|---|
void |
FastMessageConsumer.accept(Message message)
Handle an incoming message
|
Modifier and Type | Method and Description |
---|---|
void |
CmeTcpReplayMessageBlockReader.messageRead(InputStream in,
Message message) |
void |
CmeMessageBlockReader.messageRead(InputStream in,
Message message) |
void |
CmeTcpReplayMessageBlockWriter.writeBlockLength(OutputStream out,
Message message,
byte[] encodedMessage) |
void |
CmeMessageBlockWriter.writeBlockLength(OutputStream out,
Message message,
byte[] encodedMessage)
Note: the CME Channel Sub ID (the fifth byte of the preamble) will always be zero.
|
Modifier and Type | Method and Description |
---|---|
void |
FileFastMessageLogger.log(Message message,
byte[] bytes,
FastMessageLogger.Direction direction) |
void |
FastMessageLogger.log(Message message,
byte[] bytes,
FastMessageLogger.Direction direction) |
Modifier and Type | Field and Description |
---|---|
static Message |
SessionControlProtocol_1_1.DYN_TEMP_REF_MESSAGE |
static Message |
SessionControlProtocol_1_1.RESET |
Modifier and Type | Method and Description |
---|---|
static Message |
SessionControlProtocol_1_1.createFastAlertMessage(ErrorCode code) |
Message |
SessionControlProtocol_1_1.createHelloMessage(String senderName) |
Message |
SessionProtocol.createTemplateDeclarationMessage(MessageTemplate messageTemplate,
int templateId) |
Message |
SessionControlProtocol_1_1.createTemplateDeclarationMessage(MessageTemplate messageTemplate,
int templateId) |
Message |
SessionProtocol.createTemplateDefinitionMessage(MessageTemplate messageTemplate) |
Message |
SessionControlProtocol_1_1.createTemplateDefinitionMessage(MessageTemplate messageTemplate) |
Message |
SessionProtocol.getCloseMessage() |
Message |
SessionControlProtocol_1_1.getCloseMessage() |
Message |
SessionProtocol.getResetMessage() |
Modifier and Type | Method and Description |
---|---|
MessageTemplate |
SessionProtocol.createTemplateFromMessage(Message templateDef,
TemplateRegistry registry) |
MessageTemplate |
SessionControlProtocol_1_1.createTemplateFromMessage(Message templateDef,
TemplateRegistry registry) |
protected QName |
SessionControlProtocol_1_1.getQName(Message message) |
void |
SessionProtocol.handleMessage(Session session,
Message message) |
void |
SessionMessageHandler.handleMessage(Session session,
Message message) |
void |
SessionControlProtocol_1_1.handleMessage(Session session,
Message message) |
boolean |
SessionProtocol.isProtocolMessage(Message message) |
boolean |
SessionControlProtocol_1_1.isProtocolMessage(Message message) |
void |
MessageListener.onMessage(Session session,
Message message) |
Modifier and Type | Method and Description |
---|---|
static Message |
GroupConverter.convert(Group group,
Message groupMsg,
ConversionContext context) |
Modifier and Type | Method and Description |
---|---|
static Message |
GroupConverter.convert(Group group,
Message groupMsg,
ConversionContext context) |
Modifier and Type | Method and Description |
---|---|
Message |
MessageTemplate.decode(InputStream in,
int templateId,
BitVectorReader presenceMapReader,
Context context)
Decodes the inputStream and creates a new message that contains this
information
|
Modifier and Type | Method and Description |
---|---|
byte[] |
MessageTemplate.encode(Message message,
Context context)
Uses the superclasses encode method to encode the byte array - see
Group.java
|
Copyright © 2006-2013 The LaSalle Technology Group, LLC. All Rights Reserved.