Uses of Interface
org.apache.activemq.artemis.api.core.client.ClientMessage
Packages that use ClientMessage
Package
Description
-
Uses of ClientMessage in org.apache.activemq.artemis.api.core.client
Methods in org.apache.activemq.artemis.api.core.client that return ClientMessageModifier and TypeMethodDescriptionClientMessage.acknowledge()Acknowledges reception of this message.ClientSession.createMessage(boolean durable) Creates a ClientMessage.ClientSession.createMessage(byte type, boolean durable) Creates a ClientMessage.ClientSession.createMessage(byte type, boolean durable, long expiration, long timestamp, byte priority) Creates a ClientMessage.ClientMessage.individualAcknowledge()Acknowledges reception of a single message.ClientMessage.putBooleanProperty(String key, boolean value) Overridden fromMessageto enable fluent APIClientMessage.putBooleanProperty(SimpleString key, boolean value) Overridden fromMessageto enable fluent APIClientMessage.putByteProperty(String key, byte value) Overridden fromMessageto enable fluent APIClientMessage.putByteProperty(SimpleString key, byte value) Overridden fromMessageto enable fluent APIClientMessage.putBytesProperty(String key, byte[] value) Overridden fromMessageto enable fluent APIClientMessage.putBytesProperty(SimpleString key, byte[] value) Overridden fromMessageto enable fluent APIClientMessage.putCharProperty(String key, char value) Overridden fromMessageto enable fluent APIClientMessage.putCharProperty(SimpleString key, char value) Overridden fromMessageto enable fluent APIClientMessage.putDoubleProperty(String key, double value) Overridden fromMessageto enable fluent APIClientMessage.putDoubleProperty(SimpleString key, double value) Overridden fromMessageto enable fluent APIClientMessage.putFloatProperty(String key, float value) Overridden fromMessageto enable fluent APIClientMessage.putFloatProperty(SimpleString key, float value) Overridden fromMessageto enable fluent APIClientMessage.putIntProperty(String key, int value) Overridden fromMessageto enable fluent APIClientMessage.putIntProperty(SimpleString key, int value) Overridden fromMessageto enable fluent APIClientMessage.putLongProperty(String key, long value) Overridden fromMessageto enable fluent APIClientMessage.putLongProperty(SimpleString key, long value) Overridden fromMessageto enable fluent APIClientMessage.putShortProperty(String key, short value) Overridden fromMessageto enable fluent APIClientMessage.putShortProperty(SimpleString key, short value) Overridden fromMessageto enable fluent APIClientMessage.putStringProperty(String key, String value) Overridden fromMessageto enable fluent APIClientConsumer.receive()Receives a message from a queue.ClientConsumer.receive(long timeout) Receives a message from a queue.ClientConsumer.receiveImmediate()Receives a message from a queue.ClientRequestor.request(ClientMessage request) Sends a message to the request address and wait indefinitely for a reply.ClientRequestor.request(ClientMessage request, long timeout) Sends a message to the request address and wait for the given timeout for a reply.ClientMessage.setBodyInputStream(InputStream bodyInputStream) Sets the body's IntputStream.ClientMessage.setDeliveryCount(int deliveryCount) Sets the delivery count for this message.ClientMessage.setOutputStream(OutputStream out) Sets the OutputStream that will receive the content of a message received in a non blocking way.ClientMessage.writeBodyBufferBytes(byte[] bytes) Overridden fromMessageto enable fluent APIClientMessage.writeBodyBufferString(String string) Overridden fromMessageto enable fluent APIMethods in org.apache.activemq.artemis.api.core.client with parameters of type ClientMessageModifier and TypeMethodDescriptionvoidMessageHandler.onMessage(ClientMessage message) Notifies the MessageHandler that a message has been received.default voidMessageHandler.onMessageExpired(ClientMessage message) Notifies the MessageHandler that an expired message has been received.ClientRequestor.request(ClientMessage request) Sends a message to the request address and wait indefinitely for a reply.ClientRequestor.request(ClientMessage request, long timeout) Sends a message to the request address and wait for the given timeout for a reply. -
Uses of ClientMessage in org.apache.activemq.artemis.api.core.management
Methods in org.apache.activemq.artemis.api.core.management with parameters of type ClientMessageModifier and TypeMethodDescriptionvoidManagementHelper.MessageAcceptor.accept(ClientMessage message) protected static voidSimpleManagement.failed(ClientMessage message) protected static voidSimpleManagement.setBooleanResult(ClientMessage m, AtomicBoolean result) protected static voidSimpleManagement.setIntResult(ClientMessage m, AtomicInteger result) protected static voidSimpleManagement.setLongResult(ClientMessage m, AtomicLong result) protected static voidSimpleManagement.setStringResult(ClientMessage m, AtomicReference<String> result) protected static voidSimpleManagement.setupCall(ClientMessage m, String resource, String methodName, Object... parameters)