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) -
Uses of ClientMessage in org.apache.activemq.artemis.core.client.impl
Subinterfaces of ClientMessage in org.apache.activemq.artemis.core.client.implModifier and TypeInterfaceDescriptioninterfaceinterfaceClasses in org.apache.activemq.artemis.core.client.impl that implement ClientMessageModifier and TypeClassDescriptionfinal classClientLargeMessageImpl is only created when receiving large messages.classMethods in org.apache.activemq.artemis.core.client.impl that return ClientMessageModifier and TypeMethodDescriptionClientSessionImpl.createMessage(boolean durable) ClientSessionImpl.createMessage(byte type, boolean durable) ClientSessionImpl.createMessage(byte type, boolean durable, long expiration, long timestamp, byte priority) ClientConsumerImpl.receive()ClientConsumerImpl.receive(long timeout) ClientConsumerImpl.receiveImmediate()Methods in org.apache.activemq.artemis.core.client.impl with parameters of type ClientMessageModifier and TypeMethodDescriptionvoidClientConsumerImpl.acknowledge(ClientMessage message) voidClientConsumerInternal.acknowledge(ClientMessage message) voidClientConsumerImpl.individualAcknowledge(ClientMessage message) voidClientConsumerInternal.individualAcknowledge(ClientMessage message) -
Uses of ClientMessage in org.apache.activemq.artemis.core.server.federation
Methods in org.apache.activemq.artemis.core.server.federation with parameters of type ClientMessageModifier and TypeMethodDescriptionvoidFederatedQueueConsumerImpl.onMessage(ClientMessage clientMessage) -
Uses of ClientMessage in org.apache.activemq.artemis.jms.client
Fields in org.apache.activemq.artemis.jms.client declared as ClientMessageMethods in org.apache.activemq.artemis.jms.client that return ClientMessageMethods in org.apache.activemq.artemis.jms.client with parameters of type ClientMessageModifier and TypeMethodDescriptionstatic ActiveMQMessageActiveMQMessage.createMessage(ClientMessage message, ClientSession session) static ActiveMQMessageActiveMQMessage.createMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options) voidJMSMessageListenerWrapper.onMessage(ClientMessage message) In this method we apply the JMS acknowledgement and redelivery semantics as per JMS specvoidJMSMessageListenerWrapper.onMessageExpired(ClientMessage message) Constructors in org.apache.activemq.artemis.jms.client with parameters of type ClientMessageModifierConstructorDescriptionprotectedActiveMQBytesMessage(ClientMessage message, ClientSession session) Constructor on receipt at client sideprotectedActiveMQMapMessage(ClientMessage message, ClientSession session) This constructor is used during readingActiveMQMessage(ClientMessage message, ClientSession session) Constructor for when receiving a message from the serverprotectedActiveMQObjectMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options) protectedActiveMQStreamMessage(ClientMessage message, ClientSession session) ActiveMQTextMessage(ClientMessage message, ClientSession session) -
Uses of ClientMessage in org.apache.activemq.artemis.jms.client.compatible1X
Methods in org.apache.activemq.artemis.jms.client.compatible1X with parameters of type ClientMessageModifier and TypeMethodDescriptionstatic ActiveMQMessageActiveMQCompatibleMessage.createMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options) Constructors in org.apache.activemq.artemis.jms.client.compatible1X with parameters of type ClientMessageModifierConstructorDescriptionprotectedActiveMQBytesCompatibleMessage(ClientMessage message, ClientSession session) ActiveMQCompatibleMessage(ClientMessage message, ClientSession session) ActiveMQMapCompatibleMessage(ClientMessage message, ClientSession session) ActiveMQObjectCompatibleMessage(ClientMessage message, ClientSession session, ConnectionFactoryOptions options) ActiveMQStreamCompatibleMessage(ClientMessage message, ClientSession session) ActiveMQTextCompatibleMessage(ClientMessage message, ClientSession session) -
Uses of ClientMessage in org.apache.activemq.artemis.ra.inflow
Methods in org.apache.activemq.artemis.ra.inflow with parameters of type ClientMessageModifier and TypeMethodDescriptionvoidActiveMQMessageHandler.onMessage(ClientMessage message) voidActiveMQMessageHandler.onMessageExpired(ClientMessage message)