ActiveMQ connect, неизвестный тип данных: 49

Я использую ActiveMQ для отправки файлов из приложения в другое, и я столкнулся с этой ошибкой, когда потребитель пытается подключиться к серверу ActiveMQ.

Вот метод подключения

public void connect()
    {
        connectionFactory = new ActiveMQConnectionFactory(
                "tcp://" + Configuration.getInstance().getServerAddress() + 
                ":61616?jms.blobTransferPolicy.defaultUploadUrl=" + "http://" +
                Configuration.getInstance().getServerAddress() + ":8161/fileserver/"
                        + "&connectionTimeout=0&soTimeout=0&soWriteTimeout=0"
                        + "&useInactivityMonitor=false");
        try 
        {
            connection = connectionFactory.createConnection();
            session = (ActiveMQSession) connection.createSession(false,
                                                    Session.AUTO_ACKNOWLEDGE);  
            destination = session.createQueue(Configuration.getInstance().getQueueName());
            consumer = session.createConsumer(destination);
            connection.start();
//          System.out.println("Consumer connected");
        } catch (JMSException e) {
            logger.error("PACS", e);
            e.printStackTrace();
        }
    }

Это точно такой же метод, который я использую для подключения производителя к ActiveMQ, и в этом случае он работает отлично, на стороне потребителя у меня возникает следующая ошибка:

javax.jms.JMSException: Unknown data type: 49
        at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSuppo
rt.java:54)
        at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnect
ion.java:1417)
        at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(Activ
eMQConnection.java:1522)
        at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnecti
on.java:328)
        at com.kratossrl.pacs.consumer.CloudPacsConsumer.connect(CloudPacsConsum
er.java:74)
        at com.kratossrl.pacs.consumer.CloudPacsConsumer.start(CloudPacsConsumer
.java:91)
        at com.kratossrl.pacs.consumer.CloudPacsConsumer.run(CloudPacsConsumer.j
ava:135)
        at com.kratossrl.pacs.consumer.CloudPacsConsumer.init(CloudPacsConsumer.
java:57)
        at com.kratossrl.pacs.consumer.CloudPacsConsumer$1.call(CloudPacsConsume
r.java:39)
        at com.kratossrl.pacs.consumer.CloudPacsConsumer$1.call(CloudPacsConsume
r.java:1)
        at javafx.concurrent.Task$TaskCallable.call(Unknown Source)
        at java.util.concurrent.FutureTask.run(Unknown Source)
        at java.lang.Thread.run(Unknown Source)
    Caused by: java.io.IOException: Unknown data type: 49
            at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireForma
    t.java:348)
            at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.
    java:268)
            at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTranspo
    rt.java:221)
            at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav
    a:213)
            at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
    196)
            ... 1 more
    javax.jms.JMSException: Unknown data type: 49
            at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSuppo
    rt.java:54)
            at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnect
    ion.java:1417)
            at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(Activ
    eMQConnection.java:1522)
            at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnecti
    on.java:328)
            at com.kratossrl.pacs.consumer.CloudPacsConsumer.connect(CloudPacsConsum
    er.java:74)
            at com.kratossrl.pacs.consumer.CloudPacsConsumer.start(CloudPacsConsumer
    .java:91)
            at com.kratossrl.pacs.consumer.CloudPacsConsumer.run(CloudPacsConsumer.j
    ava:135)
            at com.kratossrl.pacs.consumer.CloudPacsConsumer.init(CloudPacsConsumer.
    java:57)
            at com.kratossrl.pacs.consumer.CloudPacsConsumer$1.call(CloudPacsConsume
    r.java:39)
            at com.kratossrl.pacs.consumer.CloudPacsConsumer$1.call(CloudPacsConsume
    r.java:1)
            at javafx.concurrent.Task$TaskCallable.call(Unknown Source)
            at java.util.concurrent.FutureTask.run(Unknown Source)
            at java.lang.Thread.run(Unknown Source)
    Caused by:

 java.io.IOException: Unknown data type: 49
        at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireForma
t.java:348)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.
java:268)
        at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTranspo
rt.java:221)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.jav
a:213)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
196)
        ... 1 more

Я искал в сети эту ошибку, но не нашел значение "49".

Кто-нибудь сталкивался с моей ситуацией или знает причину / решение этой проблемы?

Спасибо за совет и извините за мой не идеальный английский

Источник

1 ответ

Перепроверьте ваши версии ActiveMQ, почти кажется, что клиент более новый, чем сервер, и когда они согласовывают протокол, клиент отправляет что-то непонятное серверу, и выдается исключение

Источник
Другие вопросы по тегам