Module io.helidon.messaging.connectors.jms

Package io.helidon.messaging.connectors.jms

Class JmsBytesMessage

java.lang.Object

io.helidon.messaging.connectors.jms.JmsBytesMessage

All Implemented Interfaces:

JmsMessage<byte[]>, Message<byte[]>

public class JmsBytesMessage
extends Object

A JMS Bytes message representation.

Nested Class Summary

Nested classes/interfaces inherited from interface io.helidon.messaging.connectors.jms.JmsMessage

JmsMessage.CustomMapper<PAYLOAD>, JmsMessage.OutgoingJmsMessageBuilder<PAYLOAD>

Method Summary

Modifier and Type	Method	Description
CompletionStage<Void>	ack()
InputStream	asInputStream()	Return InputStream which is able to read JMS ByteMessage.
javax.jms.Connection	getJmsConnection()	Get client's connection to its JMS provider.
javax.jms.ConnectionFactory	getJmsConnectionFactory()	Get JMS connection factory.
javax.jms.BytesMessage	getJmsMessage()	Original JMS message received.
javax.jms.Session	getJmsSession()	Metadata about the JMS session.
byte[]	getPayload()
<P> P	getProperty(String name)	Get JMS property by name.
Set<String>	getPropertyNames()	Return set of all JMS property names.
boolean	hasProperty(String name)	Check if JMS property exists.
boolean	isAck()	Check if message has been acknowledged yet.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.helidon.messaging.connectors.jms.JmsMessage

getCorrelationId, getReplyTo, getType

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message

unwrap

Method Detail

getJmsMessage

public javax.jms.BytesMessage getJmsMessage()

Description copied from interface: JmsMessage

Original JMS message received.

Returns:

original JMS message received

asInputStream

public InputStream asInputStream()

Return InputStream which is able to read JMS ByteMessage.

Returns:

InputStream supplying bytes from received JMS ByteMessage.

getPayload

public byte[] getPayload()

getProperty

public <P> P getProperty(String name)

Description copied from interface: JmsMessage

Get JMS property by name.

Specified by:

getProperty in interface JmsMessage<T>

Type Parameters:

P - expected type of the property, has to be Boolean, Byte, Short, Integer, Long, Float, Double or String

Parameters:

name - the name of the JMS property

Returns:

property value with the specified name or null

hasProperty

public boolean hasProperty(String name)

Description copied from interface: JmsMessage

Check if JMS property exists.

Specified by:

hasProperty in interface JmsMessage<T>

Parameters:

name - the name of the JMS property

Returns:

true if property exists

getPropertyNames

public Set<String> getPropertyNames()

Description copied from interface: JmsMessage

Return set of all JMS property names.

Specified by:

getPropertyNames in interface JmsMessage<T>

Returns:

JMS property names

getJmsSession

public javax.jms.Session getJmsSession()

Description copied from interface: JmsMessage

Metadata about the JMS session.

Specified by:

getJmsSession in interface JmsMessage<T>

Returns:

JMS session

getJmsConnection

public javax.jms.Connection getJmsConnection()

Description copied from interface: JmsMessage

Get client's connection to its JMS provider.

Specified by:

getJmsConnection in interface JmsMessage<T>

Returns:

JMS connection

getJmsConnectionFactory

public javax.jms.ConnectionFactory getJmsConnectionFactory()

Description copied from interface: JmsMessage

Get JMS connection factory.

Specified by:

getJmsConnectionFactory in interface JmsMessage<T>

Returns:

JMS connection factory

isAck

public boolean isAck()

Description copied from interface: JmsMessage

Check if message has been acknowledged yet.

Specified by:

isAck in interface JmsMessage<T>

Returns:

true if message has been acknowledged

ack

public CompletionStage<Void> ack()

Specified by:

ack in interface Message<T>