Hi I am using qpid-jms (qpid-jms-client-0.20.0-SNAPSHOT.jar) with the C++ qpid broker version 0.34 from java.
I can successfully package and receive standard Message and TextMessage types but when I try to use a ByteMessage or a MapMessage type I never receive the message. I have included two examples below. I can provide more information if needed. I am hoping this is something simple that I am doing wrong. Thanks. -bill THIS WORKS: public void publishHostFinished( String hostName, String clientType, boolean success, String result ) { try { TextMessage message = session.createTextMessage(); message.setBooleanProperty( "finished_state", success); message.setStringProperty( "finished_result", result ); message.setStringProperty( "message_type", "FINISHED" ); publishHostTextMessage( message, hostName, clientType, null ); } catch( JMSException e ) { log.error( "Error while publishing finished for {} client {}: {}", hostName, clientType, e.getLocalizedMessage() ); } } private void publishHostTextMessage( TextMessage message, String hostName, String clientType, String body ) throws JMSException { message.setStringProperty( "host", hostName ); message.setStringProperty( "client_type", clientType ); message.setText( body ); publisher.publish( message ); } WHERE THIS WON'T: // TEST MESSAGE public void publishBufferedMessage( ) { System.out.println( "****************** PUBLISH BUFFERD MESSAGE *************************" ); Drive.Builder drive = Drive.newBuilder(); drive.setSerial( "123-456-789" ); drive.setComments( "This is drive: sda" ); drive.setId(123); drive.setLabel( "DRIVE_LABEL" ); drive.build(); try { BytesMessage message = session.createBytesMessage(); int messageSize = drive.build().getSerializedSize(); message.setStringProperty( "message_type", "DRIVE_DATA" ); message.setIntProperty( "message_encoded_size", messageSize ); /** byte[] encodedMessage = new byte[messageSize]; encodedMessage = drive.build().toByteArray(); message.writeBytes( encodedMessage ); **/ publisher.publish( message ); } catch( JMSException jmse ) { System.out.println( "error while publishing buffered message: " + jmse.getLocalizedMessage() ); } } -- View this message in context: http://qpid.2158936.n2.nabble.com/qpid-jms-with-C-Broker-Does-it-support-ByteMessage-types-from-java-tp7652144.html Sent from the Apache Qpid developers mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@qpid.apache.org For additional commands, e-mail: dev-h...@qpid.apache.org