Modifier and Type | Method and Description |
---|---|
NevadoMessage |
NevadoSession.createMessage() |
NevadoMessage |
MessageHolder.getNextMessage(javax.jms.Destination destination) |
NevadoMessage |
NevadoMessageConsumer.receive() |
NevadoMessage |
NevadoMessageConsumer.receive(long timeoutMs) |
protected NevadoMessage |
NevadoSession.receiveMessage(NevadoDestination destination,
long timeoutMs,
boolean noLocal) |
NevadoMessage |
NevadoMessageConsumer.receiveNoWait() |
Modifier and Type | Method and Description |
---|---|
List<NevadoMessage> |
MessageHolder.getConsumedMessages() |
Modifier and Type | Method and Description |
---|---|
void |
NevadoSession.acknowledgeMessage(NevadoMessage message) |
void |
MessageHolder.add(javax.jms.Destination destination,
NevadoMessage msg) |
protected void |
NevadoSession.deleteMessage(NevadoMessage... messages) |
void |
NevadoSession.expireMessage(NevadoMessage message) |
protected void |
NevadoSession.resetMessage(NevadoMessage... messages) |
protected void |
NevadoSession.sendMessage(NevadoDestination destination,
NevadoMessage message) |
Modifier and Type | Method and Description |
---|---|
protected NevadoMessage |
AbstractSQSConnector.convertSqsMessage(NevadoDestination destination,
SQSMessage sqsMessage,
boolean readOnly) |
protected NevadoMessage |
AbstractSQSConnector.deserializeMessage(String serializedMessage)
Deserializes the body of an SQS message into a NevadoMessage object.
|
NevadoMessage |
SQSConnector.receiveMessage(NevadoConnection connection,
NevadoDestination destination,
long timeoutMs) |
NevadoMessage |
AbstractSQSConnector.receiveMessage(NevadoConnection connection,
NevadoDestination destination,
long timeoutMs) |
Modifier and Type | Method and Description |
---|---|
void |
SQSConnector.deleteMessage(NevadoMessage message) |
void |
AbstractSQSConnector.deleteMessage(NevadoMessage message) |
void |
SQSConnector.resetMessage(NevadoMessage message) |
void |
AbstractSQSConnector.resetMessage(NevadoMessage message) |
void |
SQSConnector.sendMessage(NevadoDestination destination,
NevadoMessage outgoingMessage) |
void |
AbstractSQSConnector.sendMessage(NevadoDestination destination,
NevadoMessage message) |
protected String |
AbstractSQSConnector.serializeMessage(NevadoMessage message)
Serialize a NevadoMessage object into the body of an SQS message into a bae64 string.
|
Modifier and Type | Method and Description |
---|---|
void |
SQSConnector.sendMessages(NevadoDestination destination,
List<NevadoMessage> outgoingMessages) |
void |
AbstractSQSConnector.sendMessages(NevadoDestination destination,
List<NevadoMessage> outgoingMessages) |
Modifier and Type | Method and Description |
---|---|
protected NevadoMessage |
AmazonAwsSQSConnector.convertSqsMessage(NevadoDestination destination,
SQSMessage sqsMessage,
boolean readOnly) |
protected NevadoMessage |
PlainTextAmazonSQSConnector.deserializeMessage(String serializedMessage) |
Modifier and Type | Method and Description |
---|---|
protected String |
PlainTextAmazonSQSConnector.serializeMessage(NevadoMessage message) |
Modifier and Type | Method and Description |
---|---|
protected NevadoMessage |
MockSQSConnector.convertSqsMessage(NevadoDestination destination,
SQSMessage sqsMessage,
boolean readOnly) |
Modifier and Type | Class and Description |
---|---|
class |
InvalidMessage
Created by IntelliJ IDEA.
|
class |
NevadoBlankMessage
Created by IntelliJ IDEA.
|
class |
NevadoBytesMessage
This class borrrows heavily from ActiveMQStreamMessage, Copyright 2004 Protique Ltd,
with great appreciation for its creators.
|
class |
NevadoMapMessage
Created by IntelliJ IDEA.
|
class |
NevadoObjectMessage
Created by IntelliJ IDEA.
|
class |
NevadoStreamMessage
This class borrrows heavily from ActiveMQStreamMessage, Copyright 2004 Protique Ltd,
with great appreciation for its creators.
|
class |
NevadoTextMessage |
Modifier and Type | Method and Description |
---|---|
static NevadoMessage |
NevadoMessage.getInstance(javax.jms.Message message) |
Copyright © 2014. All Rights Reserved.