Re: [osgi-dev] Osgi bundle does not keep listening to osgfiyed ActiveMq broker

2017-02-24 Thread Mestiri Meher 
I did resolved my issue, it was a rooky mistake as I'm new over osgi and
had no experience working with threading.
Right now it's ok for me I resolved the issue.
If I could help lemme know.


2017-02-24 9:44 GMT+01:00 Mestiri Meher :

> I don't know if you received or not the bundles, I'll try again:
>
> 2017-02-24 9:43 GMT+01:00 Mestiri Meher :
>
>> Hey here are my bundles :)
>>
>> Just rename'em into .zip
>>
>> 2017-02-24 9:19 GMT+01:00 Randy Leonard :
>>
>>> First, a comment:
>>>  - Your issue is with the consumer, but you have provided code for the
>>> producer ;)
>>>
>>> You will see on the subsequent post I am also having an issue with
>>> Apache MQ.  Some questions:
>>>  - Are you using 'activemq-all-5.14.3', or 'activemq-osgi-5.14.3’
>>>  - If you wish to zip up your project for me… I’ll send back a working
>>> example for you
>>>
>>> Thanks,
>>> Randy
>>>
>>>
>>> On Feb 23, 2017, at 3:55 PM, Mestiri Meher 
>>> wrote:
>>>
>>> Hello guys,
>>>
>>> I was able to bundle the ActiveMQ and push it into the Apache Felix
>>> context but I faced an issue when I started playing with it:
>>>
>>> Here is the scenario :
>>> 1/ I created the ActiveMQ bundle inside apache felix, I run it and it
>>> listens to the needed port. 2/ I created the producer bundle and putted
>>> all the needed connection and queue creation in the start method. 3/ I
>>> created the consumer bundle following the same strategy Once I start
>>> the producer, I can see my message sent. Once I run the consumer it's
>>> ok I can see the message received, the issue is once I stop the
>>> producer bundle and I restart it, I was waiting to get a notification from
>>> my consumer bundle but not, I do have to restart the consumer so it knows
>>> about the new message and throw it out. Do you have an idea on how
>>> could I get notified by my bundle once a new message pushed into the broker
>>> queue ?
>>>
>>>
>>> I'm thinking about the fact that I did not used the multithreading, but
>>> I'm not sure, in the activeMq tutos it creates the producers/consumers
>>> using threads.
>>> So probably that's the issue..
>>>
>>> Do I have to register my bundle in the osgi service registry ?!
>>>
>>>
>>> Here is the code I'm using inside my bundle and start method (it does
>>> not implement runnable or runs this inside a thread):
>>>
>>>  //this is my start method
>>>// Create a ConnectionFactory
>>> ActiveMQConnectionFactory connectionFactory = new 
>>> ActiveMQConnectionFactory("vm://localhost");
>>>
>>> // Create a Connection
>>> Connection connection = connectionFactory.createConnection();
>>> connection.start();
>>>
>>> // Create a Session
>>> Session session = connection.createSession(false, 
>>> Session.AUTO_ACKNOWLEDGE);
>>>
>>> // Create the destination (Topic or Queue)
>>> Destination destination = session.createQueue("TEST.FOO");
>>>
>>> // Create a MessageProducer from the Session to the Topic or 
>>> Queue
>>> MessageProducer producer = session.createProducer(destination);
>>> producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
>>>
>>> // Create a messages
>>> String text = "Hello world! From: " + 
>>> Thread.currentThread().getName() + " : " + this.hashCode();
>>> TextMessage message = session.createTextMessage(text);
>>>
>>> // Tell the producer to send the message
>>> System.out.println("Sent message: "+ message.hashCode() + " : " 
>>> + Thread.currentThread().getName());
>>> producer.send(message);
>>>
>>> // Clean up
>>> session.close();
>>> connection.close();
>>>
>>>
>>>
>>> Thanks all for your help and sharing about osgi!
>>> ___
>>> OSGi Developer Mail List
>>> osgi-dev@mail.osgi.org
>>> https://mail.osgi.org/mailman/listinfo/osgi-dev
>>>
>>>
>>>
>>> ___
>>> OSGi Developer Mail List
>>> osgi-dev@mail.osgi.org
>>> https://mail.osgi.org/mailman/listinfo/osgi-dev
>>>
>>
>>
>
___
OSGi Developer Mail List
osgi-dev@mail.osgi.org
https://mail.osgi.org/mailman/listinfo/osgi-dev

Re: [osgi-dev] Osgi bundle does not keep listening to osgfiyed ActiveMq broker

2017-02-24 Thread Randy Leonard 
First, a comment:
 - Your issue is with the consumer, but you have provided code for the producer 
;)

You will see on the subsequent post I am also having an issue with Apache MQ.  
Some questions:
 - Are you using 'activemq-all-5.14.3', or 'activemq-osgi-5.14.3’
 - If you wish to zip up your project for me… I’ll send back a working example 
for you

Thanks,
Randy


> On Feb 23, 2017, at 3:55 PM, Mestiri Meher  wrote:
> 
> Hello guys,
> 
> I was able to bundle the ActiveMQ and push it into the Apache Felix context 
> but I faced an issue when I started playing with it:
> 
> Here is the scenario : 
> 
> 1/ I created the ActiveMQ bundle inside apache felix, I run it and it listens 
> to the needed port.
> 2/ I created the producer bundle and putted all the needed connection and 
> queue creation in the start method.
> 3/ I created the consumer bundle following the same strategy
> 
> Once I start the producer, I can see my message sent.
> Once I run the consumer it's ok I can see the message received, 
> the issue is once I stop the producer bundle and I restart it, I was waiting 
> to get a notification from my consumer bundle but not, I do have to restart 
> the consumer so it knows about the new message and throw it out.
> Do you have an idea on how could I get notified by my bundle once a new 
> message pushed into the broker queue ?
> 
> 
> I'm thinking about the fact that I did not used the multithreading, but I'm 
> not sure, in the activeMq tutos it creates the producers/consumers using 
> threads.
> So probably that's the issue..
> 
> Do I have to register my bundle in the osgi service registry ?! 
> 
> 
> Here is the code I'm using inside my bundle and start method (it does not 
> implement runnable or runs this inside a thread):
> 
>  //this is my start method
>// Create a ConnectionFactory
> ActiveMQConnectionFactory connectionFactory = new 
> ActiveMQConnectionFactory("vm://localhost");
> 
> // Create a Connection
> Connection connection = connectionFactory.createConnection();
> connection.start();
> 
> // Create a Session
> Session session = connection.createSession(false, 
> Session.AUTO_ACKNOWLEDGE);
> 
> // Create the destination (Topic or Queue)
> Destination destination = session.createQueue("TEST.FOO");
> 
> // Create a MessageProducer from the Session to the Topic or Queue
> MessageProducer producer = session.createProducer(destination);
> producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
> 
> // Create a messages
> String text = "Hello world! From: " + 
> Thread.currentThread().getName() + " : " + this.hashCode();
> TextMessage message = session.createTextMessage(text);
> 
> // Tell the producer to send the message
> System.out.println("Sent message: "+ message.hashCode() + " : " + 
> Thread.currentThread().getName());
> producer.send(message);
> 
> // Clean up
> session.close();
> connection.close();
> 
> 
> Thanks all for your help and sharing about osgi!
> ___
> OSGi Developer Mail List
> osgi-dev@mail.osgi.org
> https://mail.osgi.org/mailman/listinfo/osgi-dev

___
OSGi Developer Mail List
osgi-dev@mail.osgi.org
https://mail.osgi.org/mailman/listinfo/osgi-dev