How do I configure ActiveMQ with STOMP?

I'm using stomp.py as a client for ActiveMQ to talk to VeriFIX. Verifix uses JMS.

There is an API topic to send commands to and a API.RESPONSE topic to receive responses.

Only the header arrives at the stomp client, but not the actual payload.

I seem to need to configure Message transformations on order for ActiveMQ to know how to serialize messages to STOMP clients.

http://activemq.apache.org/stomp.html mentions XStream (XML) and Jettison (JSON)

How do I configure XStream or Jettison?

(EDITED) SOLUTION:

The solution is to include a 'transformation' header.

Valid values are: jms-map-json or jms-map-xml

Here is what the subscribe frame should look like.

SUBSCRIBE ack:auto destination:/topic/VERIFIX.API.REPLY transformation:jms-map-json ^@

After finding this I still can't find it in the ActiveMQ documentation.

Is this documented anywhere?

-------------Problems Reply------------

Since you don't provide any detailed information just some general points which might help:

Here is a walkthrough including source on how someone else solved a similar scenario...

These are links including tutorials and source providing reference information on STOMP/XStream etc.:

  • http://stomp.fusesource.org/documentation/php/book.html#Message_Transformation
  • http://xstream.codehaus.org/converter-tutorial.html
  • http://xstream.codehaus.org/annotations-tutorial.html
  • http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/transport/stomp/SamplePojo.java?view=markup
Category:python Views:2 Time:2012-03-02

Related post

  • How to use JMS Message Transformation in ActiveMQ with Stomp/JSON 2008-12-31

    I am sending messages in JSON format to an ActiveMQ server. I am trying to use JMS Transformation to transform the JSON encoded object into a true Java Object in hopes of being able to use selectors on the data inside. Here is a link to the documenta

  • Configuring ActiveMQ to load balance and reconnect 2013-01-20

    Using Java how do i configure ActiveMQ to load balance and reconnect when disconnection occur? As i understand those configuration should be made on the ActiveMQConnectionFactory object. --------------Solutions------------- To do that, you set the br

  • How to configure ActiveMQ to assign an 'anonymous' user and role to non-authenticated users 2009-01-14

    I wish to set up a ActiveMQ instance (primarily as a STOMP server) which will service requests from two types of clients: authenticated users which can read and write to topics non-authenticated users which can only read from topics I have been using

  • How to connect to ActiveMQ broker (stomp protocol,activemessaging) running in another Machine? 2010-08-19

    Basically, I have 2 MQs running on different machines(ubuntu). I need them to be able to communicate with one another. I have my broker.yml,on machine A, like this; development: adapter: stomp login: "" passcode: "" host: localhost port: 61613 reliab

  • How can I configure ActiveMQ to drop a consumer if it just stops accepting data? 2010-05-24

    Today, I saw many errors on my ActiveMQ 5.3.2 console: INFO | Usage Manager Memory Limit reached. Stopping producer (ID:...) to prevent flooding topic://mytopic. See http://activemq.apache.org/producer-flow-control.html for more info (blocking for: 3

  • How to configure ActiveMQ JCA connector in JBoss to use XA connections? 2010-07-02

    On JBoss 5.1.0 I have Datasource (PostgreSQL 8.3.11) configured using *-ds.xml (standard jboss DS). It uses XADataSource (PGXADataSource). I also have ActiveMQ broker (right now it runs as in-VM, under JBoss, but it will be on separate server latter)

  • How to build ActiveMQ-CPP Stomp only client 2011-10-12

    Is it possible to build an ActiveMQ-CPP Client to support only STOMP Protocol? Regular native library with dependencies is too big for my embedded device and I want to build a client with just the STOMP support. Please advise. Thank you. ------------

  • Can I configure Apache ActiveMQ to use the STOMP protocol over UDP? 2010-04-22

    I'm developing a STOMP binding for Ada, which is working fine utilizing TCP/IP as the transport between the client and an ActiveMQ server configured as a STOMP broker. I thought to support UDP as well (i.e. STOMP over UDP), however, the lack of perti

  • How can i configure Custom Plugins for ActiveMQ 2011-06-09

    Since i didn't get a working answer on the mailinglist i try it here. The Documentation says its possible to configure your own plugins like that: <plugins> <bean id="myPlugin" class="org.myorg.MyPlugin"/> </plugins> I tried this wi

  • HornetQ and ActiveMQ CMS don't work together! 2010-11-17

    I'm trying to implement a solution using HornetQ. Since I need to access it through a C++ application, that raises me a problem. I'm compiling the activemq-cpp builtin example, and changing it to work with stomp instead of openwire (HornetQ doesn't u

  • Multicasting, Messaging, ActiveMQ vs. MSMQ? 2008-08-28

    I'm working on a messaging/notification system for our products. Basic requirements are: Fire and forget Persistent set of messages, possibly updating, to stay there until the sender says to remove them The libraries will be written in C#. Spring.NET

  • Jboss As 5 and activemq 2010-07-27

    Does anybody know how to configure Activemq on Jboss 5.1? If so could he or she provide me with the example? Many thanks for any answer! Agata --------------Solutions------------- The instructions at this tutorial should help you http://activemq.apac

  • What solution should I use for this webapp with websockets. ActiveMQ? 2011-02-16

    I'm currently in the middle of developing a webapplication which needs a websocket connection to receive notifications of events from the server. The clients are separated in groups and all the clients in a group must receive the same event notificat

  • Sending message to ActiveMQ over internet 2011-02-17

    I want to implement messaging over internet. But didn't have IP Public yet. So I want to ask any one here about sending message to ActiveMQ using JMS over internet? Could It be done ? --------------Solutions------------- Yes, it exposes a normal TCP

  • ActiveMQ view raw message data in web console 2011-05-16

    I'm using the web console against my AMQ 5.2 instance successfully, except for I cannot see the content of all of my messages. If I send a test message using the web console, I can see the sample text content, but I believe the vendor app I am workin

  • Jetty inside ActiveMQ: Web console URL 2011-08-16

    I have an ubuntu machine, on which a) a web application (Tomcat, on URL http://myapp.com ) and b) a message queue broker (ActiveMQ) are running. ActiveMQ has a web console, which normally runs on port 8161 (i. e. at http://AAA.BBB.CCC.DDD:8161/admin

  • Activemq topic subscribers heap memory leak - why are messages increasing? 2011-11-21

    I have console application which connects to activemq topics. Abount 10 messages per second are published on each topic. After some time monitored that the application memory is increasing and when all the memory is used the application crashes. See

  • Real-time auction updates - Comet? Tornado? ActiveMQ? 2011-11-28

    I'm in the process of deciding how to write an online auction application. I would like to provide real-time updates to the site users. My background is with LAMP (although, in my case, the 'P' would be more for Perl than PHP). I've considered Active

  • JMS/ActiveMQ Dynamic Creation/Removal of topics 2012-01-18

    I have looked around and can't find a good answer to what I'm trying to figure out. In my system, I am creating topics at runtime where there is a single consumer and single producer for the topics being created at runtime. What I would like input on

Copyright (C) dskims.com, All Rights Reserved.

processed in 0.089 (s). 11 q(s)