-
Methods in org.pipservices3.messaging.queues with parameters of type MessageEnvelop
Modifier and Type |
Method |
Description |
void |
IMessageQueue.abandon(MessageEnvelop message) |
Returns message into the queue and makes it available for all subscribers to
receive it again.
|
void |
MemoryMessageQueue.abandon(MessageEnvelop message) |
Returnes message into the queue and makes it available for all subscribers to
receive it again.
|
abstract void |
MessageQueue.abandon(MessageEnvelop message) |
Returnes message into the queue and makes it available for all subscribers to
receive it again.
|
void |
IMessageQueue.complete(MessageEnvelop message) |
Permanently removes a message from the queue.
|
void |
MemoryMessageQueue.complete(MessageEnvelop message) |
Permanently removes a message from the queue.
|
abstract void |
MessageQueue.complete(MessageEnvelop message) |
Permanently removes a message from the queue.
|
void |
IMessageQueue.moveToDeadLetter(MessageEnvelop message) |
Permanently removes a message from the queue and sends it to dead letter
queue.
|
void |
MemoryMessageQueue.moveToDeadLetter(MessageEnvelop message) |
Permanently removes a message from the queue and sends it to dead letter
queue.
|
abstract void |
MessageQueue.moveToDeadLetter(MessageEnvelop message) |
Permanently removes a message from the queue and sends it to dead letter
queue.
|
void |
IMessageReceiver.receiveMessage(MessageEnvelop message,
IMessageQueue queue) |
Receives incoming message from the queue.
|
void |
IMessageQueue.renewLock(MessageEnvelop message,
long lockTimeout) |
Renews a lock on a message that makes it invisible from other receivers in
the queue.
|
void |
MemoryMessageQueue.renewLock(MessageEnvelop message,
long lockTimeout) |
Renews a lock on a message that makes it invisible from other receivers in
the queue.
|
abstract void |
MessageQueue.renewLock(MessageEnvelop message,
long lockTimeout) |
Renews a lock on a message that makes it invisible from other receivers in
the queue.
|
void |
IMessageQueue.send(String correlationId,
MessageEnvelop envelop) |
Sends a message into the queue.
|
void |
MemoryMessageQueue.send(String correlationId,
MessageEnvelop message) |
Sends a message into the queue.
|
abstract void |
MessageQueue.send(String correlationId,
MessageEnvelop message) |
Sends a message into the queue.
|