Отправка сообщений через интерфейс REST HornetQ

Я работаю с интерфейсом REST версии Hornetq 2.2.5, работающим как JMS-провайдер сервера приложений JBoss-4.2.1 GA. Я успешно развернул .war, в котором есть интерфейс обмена сообщениями HornetQ REST. Я могу правильно отправлять сообщения, используя ресурсы приложения. Теперь я пытаюсь отправить сообщения на удаленный ресурс REST, поэтому я отправил запрос HEAD, получил заголовок msg-push-consumer и отправил следующий запрос POST:

<push-registration>  
   <link href="http://remotehost:8081/TestREST/webresources/test" method="PUT" />
</push-registration>

Я просмотрел журнал JBoss и прочитал:

18: 04: 20,953 INFO [PushConsumer] Отправка потребителя запущена для: XmlLink {className = 'null', rel = 'null', href = 'http: // remotehost: 8081 / TestREST / webresources / test', type = 'null ', method =' PUT '}

Но когда я пытаюсь отправить тестовое сообщение JMS в очередь, у меня возникает следующее исключение:

18: 07: 08,234 ОШИБКА [ClientConsumerImpl] Не удалось вызвать исключение onMessage () java.lang.IndexOutOfBoundsException в org.jboss.netty.buffer.AbstractChannelBuffer.checkReadableBytes (AbstractChannelBuffer.java:657hassus.com) на org. readBytes (AbstractChannelBuffer.java:337) в org.jboss.netty.buffer.AbstractChannelBuffer.readBytes (AbstractChannelBuffer.java:343) в org.hornetq.core.buffers.impl.ChannelBufferWrapper: ChannelBufferWrapper.readBufferWrapper. .hornetq.rest.util.HttpMessageHelper.buildMessage (HttpMessageHelper.java:97) в org.hornetq.rest.queue.push.UriStrategy.push (UriStrategy.java:82) в org.hornetq.mer.queue.push.push.push. .onMessage (PushConsumer.java:114) в org.hornetq.core.client.impl.ClientConsumerImpl.callOnMessage (ClientConsumerImpl.java:866) в org.hornetq.core.client.impl.ClientConsumerImpl Client.access $ 100 44) в org.hornetq.core.client.impl.ClientConsumerImpl $ Runner.run (ClientConsumerImpl.java:983) в org.hornetq.utils.OrderedExecutorFactory $ OrderedExecutor $ 1.run (OrderedExecutorFactory.javacurrent.java:100) в ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1110) в java.util.concurrent.ThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:603) в java.lang.Thread.run (Thread.java:722)

У вас есть идея решить проблему?


person Paco Saucedo    schedule 28.09.2012    source источник


Ответы (1)


Можете сначала попробовать последние версии? Было несколько изменений. Я бы порекомендовал 2.2.14

Тогда мы сможем изучить возможную ошибку. Нам понадобится репликатор для вашей проблемы.

person Clebert Suconic    schedule 09.10.2012