Hi Chandresh, I think I'm not the best person who can help you with streamer. I'd recommend you to look at ignite/modules/mqtt where you can find MqttStreamer implementation with tests which already has been reviewed.
Also, I've been moved the jira [1] from Patch Available status to Open as long as patch is not ready for review. [1] https://issues.apache.org/jira/browse/IGNITE-429. -- Artem -- On Wed, Oct 28, 2015 at 8:36 AM, chandresh pancholi < chandreshpancholi...@gmail.com> wrote: > Artem, > Can you please specifically point to already written tests. I have been > stuck with this JIRA ticket since long time and i want to finish it ASAP. > > If possible can you check out my code.? > https://github.com/chandresh-pancholi/ignite > module - storm > > On Tue, Oct 27, 2015 at 7:15 AM, Dmitriy Setrakyan <dsetrak...@apache.org> > wrote: > > > On Mon, Oct 26, 2015 at 9:23 AM, Saikat Maitra <saikat.mai...@gmail.com> > > wrote: > > > > > Hi > > > > > > Quick questions on the node startup. > > > > > > 1. What is the port defined in default-config.xml ? > > > > > > > I believe that the default discovery port is 47500. You can specify a > > different port if you like. > > > > > > > 2. if a listener is already running on that port then will the second > > > node will automatically detect and start on another port? > > > > > > > The default port range is 100, so Ignite will automatically pick the next > > available port in the range. > > > > > > > > > > Regards > > > Saikat > > > > > > On Mon, Oct 26, 2015 at 7:13 PM, Artem Shutak <ashu...@gridgain.com> > > > wrote: > > > > > > > My mistake. IgniteConfiguration.setGridName(). > > > > > > > > -- Artem -- > > > > > > > > On Mon, Oct 26, 2015 at 4:42 PM, Artem Shutak <ashu...@gridgain.com> > > > > wrote: > > > > > > > > > Hi Chandresh, > > > > > > > > > > As I understand you want to run cluster (more than one Ignite node) > > in > > > > one > > > > > JVM. In the case you should specify different names for nodes via > > > > > IgniteConfiguration.setName(). > > > > > > > > > > I strongly recommend you do not invent the wheel and extend your > test > > > > > class from GridAbstarctTest which has methods to start/stop grids > and > > > do > > > > a > > > > > lot other really useful staff. > > > > > > > > > > Also, you can look at any Ignite test where all your problems have > > been > > > > > already solved :) > > > > > > > > > > -- Artem -- > > > > > > > > > > On Mon, Oct 26, 2015 at 11:03 AM, chandresh pancholi < > > > > > chandreshpancholi...@gmail.com> wrote: > > > > > > > > > >> Hi igniters, > > > > >> > > > > >> i am starting two ignite node with same config > > > > >> file(Ignition.start("config/default-config.xml");). > > > > >> One node i am starting in onStart Method of test and another is in > > my > > > > >> streamer which close every time. > > > > >> > > > > >> So one node is always up and another is start-stop. > > > > >> > > > > >> By doing this i am getting exception saying > > > > >> org.apache.ignite.IgniteException: > > > > >> Default grid instance has already been started. > > > > >> > > > > >> Because of this exception i am not able to proceed further. > > > > >> > > > > >> Please help me out here. > > > > >> > > > > >> > > > > >> -- > > > > >> Chandresh Pancholi > > > > >> Senior Software Engineer > > > > >> Flipkart.com > > > > >> Email-id:chandresh.panch...@flipkart.com > > > > >> Contact:08951803660 > > > > >> > > > > > > > > > > > > > > > > > > > > > > > -- > Chandresh Pancholi > Senior Software Engineer > Flipkart.com > Email-id:chandresh.panch...@flipkart.com > Contact:08951803660 >