Hi Imesh,
On Wed, Oct 16, 2013 at 10:56 AM, Imesh Gunaratne <[email protected]> wrote: > Hi, > > Please find the below sample for publishing and receiving an event message > using the new messaging system. > * > * > *Publishing an Event Message* > > ... > ServiceCreatedEvent event = new ServiceCreatedEvent(); > event.setServiceName("AppServer"); > TopologyEventMessage message = new TopologyEventMessage(event); > publisher.sendMessage(message.getJson()); > > * > * > *Receiving an Event Message* > > package org.apache.stratos.messaging.message; > > class MessageProcessor { > private Object jsonToObject(String json, Class type) { > ... > } > > public EventMessageHeader readHeader(String json) { > Are we reading header from Json message? I thought we would use real message headers without looking at message at all. Thanks. > ... > } > } > > > class TopologyEventMessageProcessor extends MessageProcessor { > public void run() { > ... > String json = subscriber.receive(); > // Read message header to identify the event, this will only parse > the header > EventMessageHeader header = readHeader(json); > > if > (header.getEventClassName().equals(ServiceCreatedEvent.class.getName())) { > // Read the complete message and build the event > TopologyEventMessage message = jsonToObject(json, > TopologyEventMessage.class); > ServiceCreatedEvent event = jsonToObject(message.getBody(), > ServiceCreatedEvent.class); > ... > } > } > } > > *jndi.properties File Content* > connectionfactoryName=topicConnectionfactory > connectionfactory.topicConnectionfactory=amqp://admin:admin@carbon > /carbon?brokerlist='tcp://localhost:5677' > > java.naming.factory.initial=org.wso2.andes.jndi.PropertiesFileInitialContextFactory > > > Thanks > Imesh > -- -- Lahiru Sandaruwan Software Engineer, Platform Technologies, WSO2 Inc., http://wso2.com lean.enterprise.middleware email: [email protected] cell: (+94) 773 325 954 blog: http://lahiruwrites.blogspot.com/ twitter: http://twitter.com/lahirus linked-in: http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146
