siddhi-io / siddhi-io-jms Goto Github PK
View Code? Open in Web Editor NEWExtension that used to receive and publish events via JMS Message
Home Page: https://siddhi-io.github.io/siddhi-io-jms/
License: Apache License 2.0
Extension that used to receive and publish events via JMS Message
Home Page: https://siddhi-io.github.io/siddhi-io-jms/
License: Apache License 2.0
Description:
There is an issue when sending the events with mapping type "keyvalue" where the event key values are not mapping into siddhi event.
Steps to reproduce:
Steps:
[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.
App1: source the JMS messages from the ActiveMQ server.
@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;
App2: simulate the stream and publish message into ActiveMQ server.
@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;
It is better to update readme.md file and site docs for documentation purpose.
Description:
Add a fine tuning guide referring to[1]. Also review all default values and make sure suitable values are set.
Affected Product Version:
4.0.0 and above
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.