siddhi-io / siddhi-io-jms Goto Github PK

[2017-12-15 05:54:29,028] ERROR {org.wso2.extension.siddhi.map.keyvalue.sourcemapper.KeyValueSourceMapper} - Stream "SweetProductionStream" has an attribute named "name", but the received event {} does not has a value for that attribute. Hence dropping the message.

@App:name('ReceiveJMSInJsonFormat')
@source(type='jms',@map(type='keyvalue'),
factory.initial='org.apache.activemq.jndi.ActiveMQInitialContextFactory',
provider.url='tcp://localhost:61616',destination='SP_JMS_TEST', connection.factory.type='topic', 
connection.factory.jndi.name='TopicConnectionFactory',transport.jms.SubscriptionDurable='true',
transport.jms.DurableSubscriberClientID='wso2SPclient1')
define stream SweetProductionStream(name string, amount double);

from SweetProductionStream#log("Event: ")
insert into IgnoreOutputStream;

@App:name("SiddhiApp")
@app:description("Description of the plan")
@source(type='inMemory' , topic='option_value')
define stream inMemoryStream (name string, amount double);
@sink(type='jms',factory.initial='org.apache.activemq.jndi.ActiveMQInitialContextFactory', 
provider.url='tcp://localhost:61616',destination='SP_JMS_TEST', connection.factory.type='topic', connection.factory.jndi.name='TopicConnectionFactory', 
@map(type='keyvalue')) 
define stream jmsClientStream (name string, amount double);
from inMemoryStream
select name, amount
insert into jmsClientStream;