How do I publish a bytearray on the Solace Direct Publisher?

Hey @sheanne,

I was able to run a simple script locally and it worked with passing a byte array. A couple of questions:

1. What is the encoding that you are passing to bytearray in outbound_msg = bytearray(msg) ?
2. In your MessageHandlerImpl, what do you get if you dump the message directly print(f'\n Message dump: {message}') (instead of using the message_dump variable)?

You can also get the payload as a byte in your MessageHandlerImpl as follows

class MessageHandlerImpl(MessageHandler):
    def on_message(self, message: InboundMessage):
        payload_byte = message.get_payload_as_bytes()
        # print("\n" + f"Message Payload String: {message.get_payload_as_string()} \n")
        # print("\n" + f"Message Topic: {message.get_destination_name()} \n")
        print("\n" + f"Message dump: {message} \n")
        print("\n" + f"Message byte: {payload_byte} \n")

Running the following I am able to dump the message and the byte payload

# Build a Receiver with the given topics and start it
direct_receiver = messaging_service.create_direct_message_receiver_builder()\
    .with_subscriptions(TopicSubscription.of("test/>"))\
    .build()

direct_receiver.start()
direct_receiver.receive_async(MessageHandlerImpl())

# Create a direct message publisher and start it
direct_publisher = messaging_service.create_direct_message_publisher_builder().build()

# Blocking Start thread
direct_publisher.start()

topic = Topic.of("test/topic")
outbound_msg = bytearray("Hello world", encoding='utf8')

try:
    try:
        while True:
            direct_publisher.publish(destination=topic, message=outbound_msg)
            time.sleep(1)
    except KeyboardInterrupt:
        print('\nDisconnecting Messaging Service')
finally:
    print('\nTerminating receiver')
    direct_receiver.terminate()
    print('\nTerminating Publisher')
    direct_publisher.terminate()
    print('\nDisconnecting Messaging Service')
    messaging_service.disconnect()