Convert ClientMessage to TextMessage

[123avi]

Our server uses org.hornetq.api.core.client ClientMessage and user trying to send a message to the queue using jms TextMessage .

receive code

def createReceiveActor(receiveMethod: MessageBusClient.PartialReceiveType): ActorRef = {

// create the actor
val caller =
  actorOf(new Actor {
    protected def receive = {
      case message: org.hornetq.api.core.client.ClientMessage => {
              val text = message.getBodyBuffer.readString}}

sender code

session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
producer = session.createProducer(queue) 
val txtMessage:javax.jms.TextMessage = session.createTextMessage("helloWorld") 
producer.send(txtMessage)

is there a way that the receiver will read the message without using JMS ? converting the avax.jms.TextMessage to org.hornetq.api.core.client.ClientMessage ?

[ataylor]

just use the core API instead of JMS, there are some examples in the docs and also in the distribution. or look at the javadocs

[123avi]

Thanks. I Tried that , but could not read the message

[ataylor]

the jms api is just a facade on the core api, so it will work, without example code i cant really help you

[123avi]

Thanks Andy , I really apreciate your help .

I tried to show part of the code at my original message .

but basically if the producer wirtes the message 

javax.jms.TextMessage txtMessage = session.createTextMessage("helloWorld")

and the consumer is getting the message as Client message 

org.hornetq.api.core.client.ClientMessage clientMessage .

how can he get the message body

this does not work : clientMessage.getBodyBuffer.readString

[ataylor]

Each message type will write its body buffer in a different way, I think with textMessage its a write/readNullableSimpleString, you can look at the source to see how each message does it but this is internal API stuff and may change. Alternatively just use the core API like i said (for the send as well)