Re: [osgi-dev] osgi broker bundle

2017-02-17 Thread Mestiri Meher
oki :) i'll try thay out and will let you know how it was.
As i said i'll need the broker as a bundle in my concierge container.
Will update you in this next week on my findings.
Have a great week end.
Cheers! 

On 17 Feb 2017 22:18, "Achim Nierbeck"  wrote:

> must be a typo :)
>
> mosquitto, but that's a "standalone" mqtt broker. In general it should be
> enough, depending on your use-cases :)
>
>
> https://projects.eclipse.org/projects/technology.mosquitto
>
> 2017-02-17 22:16 GMT+01:00 Mestiri Meher :
>
>> thanks guys for your answers.
>> Achim are you talking about moquito or moquette ?
>>
>> Chris, does osgfying the moquette is sthg straight forward ? do you have
>> a moquette or mosquitto already ogfyied as bundle ?
>>
>>
>> On 17 Feb 2017 21:56, "Achim Nierbeck"  wrote:
>>
>> Hi,
>>
>> I second that, and I can tell mosquito works out nicely for me.
>> If you look for a tool to investigate what data is sent to your mqtt
>> broker, I suggest mqttfx.
>> It's a nice tool to investigate your broker.
>>
>> regards, Achim
>>
>> 2017-02-17 20:42 GMT+01:00 :
>>
>>> If you really only need MQTT then I think you should be looking at a
>>> dedicated MQTT broker rather than an all-singing, all-dancing message
>>> boroker like ActiveMQ. Moquette looks promising (caveat - I haven't tried
>>> it. yet)
>>>
>>> > Hi guys,
>>> >
>>> > I'm looking on how deploying an MQTT broker into an osgi environment.
>>> >
>>> > I'm running my osgi container in an embedded environment.
>>> >
>>> > I tried installing apache Karaf as it already has the ActiveMQ broker
>>> > integration easy, but i was not able to install it as it needs some
>>> junit
>>> > libraries that does not comply with the jre embedded.
>>> >
>>> > The other solution I'm thinking of is installing the ActiveMQ broker
>>> > against Felix.
>>> >
>>> > I found in an mvn repo an osgi bundle for the activeMQ but it needs its
>>> > dependencies.
>>> >
>>> > So I tried adding them as bundles but I faced an issue right now
>>> because
>>> > when I start that bundle it asks for a dependency that I can't find it.
>>> >
>>> > ->  Unable to resolve org.apache.activemq.activemq-osgi
>>> version=5.14.3:
>>> >missing requirement org.osgi.service.blueprint;
>>> version=[1.0.0,2.0.0)]
>>> >
>>> > Do you have an idea on how I have to proceed ?
>>> >
>>> > Thanks in advance :)
>>> > Meher
>>> > ___
>>> > 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
>>>
>>
>>
>>
>> --
>>
>> Apache Member
>> Apache Karaf  Committer & PMC
>> OPS4J Pax Web  Committer
>> & Project Lead
>> blog 
>> Co-Author of Apache Karaf Cookbook 
>>
>> Software Architect / Project Manager / Scrum Master
>>
>>
>> ___
>> 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
>>
>
>
>
> --
>
> Apache Member
> Apache Karaf  Committer & PMC
> OPS4J Pax Web  Committer &
> Project Lead
> blog 
> Co-Author of Apache Karaf Cookbook 
>
> Software Architect / Project Manager / Scrum Master
>
>
> ___
> 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 broker bundle

2017-02-17 Thread Mestiri Meher
thanks guys for your answers.
Achim are you talking about moquito or moquette ?

Chris, does osgfying the moquette is sthg straight forward ? do you have a
moquette or mosquitto already ogfyied as bundle ?

On 17 Feb 2017 21:56, "Achim Nierbeck"  wrote:

Hi,

I second that, and I can tell mosquito works out nicely for me.
If you look for a tool to investigate what data is sent to your mqtt
broker, I suggest mqttfx.
It's a nice tool to investigate your broker.

regards, Achim

2017-02-17 20:42 GMT+01:00 :

> If you really only need MQTT then I think you should be looking at a
> dedicated MQTT broker rather than an all-singing, all-dancing message
> boroker like ActiveMQ. Moquette looks promising (caveat - I haven't tried
> it. yet)
>
> > Hi guys,
> >
> > I'm looking on how deploying an MQTT broker into an osgi environment.
> >
> > I'm running my osgi container in an embedded environment.
> >
> > I tried installing apache Karaf as it already has the ActiveMQ broker
> > integration easy, but i was not able to install it as it needs some junit
> > libraries that does not comply with the jre embedded.
> >
> > The other solution I'm thinking of is installing the ActiveMQ broker
> > against Felix.
> >
> > I found in an mvn repo an osgi bundle for the activeMQ but it needs its
> > dependencies.
> >
> > So I tried adding them as bundles but I faced an issue right now because
> > when I start that bundle it asks for a dependency that I can't find it.
> >
> > ->  Unable to resolve org.apache.activemq.activemq-osgi version=5.14.3:
> >missing requirement org.osgi.service.blueprint; version=[1.0.0,2.0.0)]
> >
> > Do you have an idea on how I have to proceed ?
> >
> > Thanks in advance :)
> > Meher
> > ___
> > 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
>



-- 

Apache Member
Apache Karaf  Committer & PMC
OPS4J Pax Web  Committer &
Project Lead
blog 
Co-Author of Apache Karaf Cookbook 

Software Architect / Project Manager / Scrum Master


___
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 broker bundle

2017-02-17 Thread Achim Nierbeck
Hi,

I second that, and I can tell mosquito works out nicely for me.
If you look for a tool to investigate what data is sent to your mqtt
broker, I suggest mqttfx.
It's a nice tool to investigate your broker.

regards, Achim

2017-02-17 20:42 GMT+01:00 :

> If you really only need MQTT then I think you should be looking at a
> dedicated MQTT broker rather than an all-singing, all-dancing message
> boroker like ActiveMQ. Moquette looks promising (caveat - I haven't tried
> it. yet)
>
> > Hi guys,
> >
> > I'm looking on how deploying an MQTT broker into an osgi environment.
> >
> > I'm running my osgi container in an embedded environment.
> >
> > I tried installing apache Karaf as it already has the ActiveMQ broker
> > integration easy, but i was not able to install it as it needs some junit
> > libraries that does not comply with the jre embedded.
> >
> > The other solution I'm thinking of is installing the ActiveMQ broker
> > against Felix.
> >
> > I found in an mvn repo an osgi bundle for the activeMQ but it needs its
> > dependencies.
> >
> > So I tried adding them as bundles but I faced an issue right now because
> > when I start that bundle it asks for a dependency that I can't find it.
> >
> > ->  Unable to resolve org.apache.activemq.activemq-osgi version=5.14.3:
> >missing requirement org.osgi.service.blueprint; version=[1.0.0,2.0.0)]
> >
> > Do you have an idea on how I have to proceed ?
> >
> > Thanks in advance :)
> > Meher
> > ___
> > 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
>



-- 

Apache Member
Apache Karaf  Committer & PMC
OPS4J Pax Web  Committer &
Project Lead
blog 
Co-Author of Apache Karaf Cookbook 

Software Architect / Project Manager / Scrum Master
___
OSGi Developer Mail List
osgi-dev@mail.osgi.org
https://mail.osgi.org/mailman/listinfo/osgi-dev

Re: [osgi-dev] Components are not started, although marked with immediate=true

2017-02-17 Thread BJ Hargrave
Seems like they should all be active. You may need to check with the felix-dev list about Felix SCR's handling of this.
--BJ HargraveSenior Technical Staff Member, IBM // office: +1 386 848 1781OSGi Fellow and CTO of the OSGi Alliance // mobile: +1 386 848 3788hargr...@us.ibm.com
 
 
- Original message -From: "Thomas Driessen" Sent by: osgi-dev-boun...@mail.osgi.orgTo: osgi-dev@mail.osgi.orgCc:Subject: [osgi-dev] Components are not started, although marked with immediate=trueDate: Fri, Feb 17, 2017 2:46 PM  Hi,
 
I have a problem with immediate services and hoped that you guys maybe can help.
 
I'm currently trying to implement several services within one bundle (see below for code).
I have set all of them to be immediate (by immediate=true), but still, when I start the OSGi container with my bundle in it, only Con1, InDataPort1 and OutDataPort1 are active. The rest is satisfied but not active according to felix.scr console output:
 
g! listBundleId Component Name Default State   Component Id State      PIDs (Factory PID)[  10]   test.Con1  enabled   [   0] [active      ][  10]   test.InDataPort1  enabled   [   1] [active      ][  10]   test.OutDataPort1  enabled   [   2] [active      ][  10]   test.Process1  enabled   [   3] [satisfied   ][  10]   test.Thread1_1  enabled   [   4] [satisfied   ][  10]   test.Thread1_2  enabled   [   5] [satisfied   ] 
 
Am I doing something wrong?
I assumed that all services should be started as soon as they are satisfied.
 
Any advice is highly appreciated.
 
Kind regards,
Thomas
 
@Component(immediate = true, service = IProcess.class, property = "de.uniaugsburg.smds.aadl2osgi.component.uid=test.Process1")public class Process1 implements IProcess {  
 @Reference(target = "(uid=test.Thread1_1)") private volatile IPeriodicThread thread1;  @Reference(target = "(uid=test.Thread1_2)") private volatile IPeriodicThread thread2;}
 
 
@Component(service = IPeriodicThread.class, property = "de.uniaugsburg.smds.aadl2osgi.component.uid=test.Thread1_1", immediate = true)public class Thread1_1 implements IPeriodicThread {   @Reference(target = "(uid=test.OutDataPort1)") private volatile IOutDataPort outport;  
 @Activate public void initialize_FW() {   init(); }  @Deactivate public void finalize_FW() {   deinit(); }
}
 
 
@Component(service = IPeriodicThread.class, property = "de.uniaugsburg.smds.aadl2osgi.component.uid=test.Thread1_2", immediate = true)public class Thread1_2 implements IPeriodicThread {   @Reference(target = "(uid=test.InDataPort1)") private volatile IOutDataPort outport;  
 @Activate public void initialize_FW() {   init(); }  @Deactivate public void finalize_FW() {   deinit(); }
}
 
 
@Component(service = IOutDataPort.class, property = "uid=test.OutDataPort1", immediate = true)public class OutDataPort1 implements IOutDataPort { @Reference(target = "(target=test.OutDataPort1)", cardinality = ReferenceCardinality.OPTIONAL, policyOption = ReferencePolicyOption.GREEDY) private volatile IPortConnection incomingPortConnections;  private volatile Set outgoingPortConnections = new ConcurrentSkipListSet();  @Reference(target = "(source=test.OutDataPort1)", cardinality = ReferenceCardinality.OPTIONAL, policyOption = ReferencePolicyOption.GREEDY) public void addOutgoingPortConnection(final IPortConnection con) {   outgoingPortConnections.add(con); }  public void removeOutgoingPortConnection(final IPortConnection con) {   outgoingPortConnections.remove(con); }}
 
 
@Component(service = IInDataPort.class, property = "uid=test.InDataPort1", immediate = true)@SuppressWarnings("all")public class InDataPort1 implements IInDataPort { @Reference(target = "(target=test.InDataPort1)", cardinality = ReferenceCardinality.OPTIONAL, policyOption = ReferencePolicyOption.GREEDY) private volatile IPortConnection incomingPortConnections;  private volatile Set outgoingPortConnections = new ConcurrentSkipListSet();  @Reference(target = "(source=test.InDataPort1)", cardinality = ReferenceCardinality.OPTIONAL, policyOption = ReferencePolicyOption.GREEDY) public void addOutgoingPortConnection(final IPortConnection con) {   outgoingPortConnections.add(con); }  public void removeOutgoingPortConnection(final IPortConnection con) {   outgoingPortConnections.remove(con); }}
 
 
@Component(service = IPortConnection.class, property = { "source=test.OutDataPort1", "target=test.InDataPort1" }, immediate = true)public class Con1 implements IPortConnection { @Reference(cardinality = ReferenceCardinality.OPTIONAL, policyOption = ReferencePolicyOption.GREEDY, target = "(uid=test.OutDataPort1)") private volatile IOutDataPort source;  @Reference(cardinality = ReferenceCardinality.OPTIONAL, policyOption = ReferencePolicyOption.GREEDY, target = "(uid=test.InDataPort1)") private volatile IInDataPort target;}
___OSGi Developer Mail Listosgi-dev@mail.osgi.orghttps://mail.osgi.org/mailman/listinfo/osgi-dev
 


[osgi-dev] Components are not started, although marked with immediate=true

2017-02-17 Thread Thomas Driessen

Hi,

I have a problem with immediate services and hoped that you guys maybe 
can help.


I'm currently trying to implement several services within one bundle 
(see below for code).
I have set all of them to be immediate (by immediate=true), but still, 
when I start the OSGi container with my bundle in it, only Con1, 
InDataPort1 and OutDataPort1 are active. The rest is satisfied but not 
active according to felix.scr console output:


g! list
BundleId Component Name Default State
   Component Id State  PIDs (Factory PID)
[  10]   test.Con1  enabled
   [   0] [active  ]
[  10]   test.InDataPort1  enabled
   [   1] [active  ]
[  10]   test.OutDataPort1  enabled
   [   2] [active  ]
[  10]   test.Process1  enabled
   [   3] [satisfied   ]
[  10]   test.Thread1_1  enabled
   [   4] [satisfied   ]
[  10]   test.Thread1_2  enabled
   [   5] [satisfied   ]

Am I doing something wrong?
I assumed that all services should be started as soon as they are 
satisfied.


Any advice is highly appreciated.

Kind regards,
Thomas


@Component(immediate = true, service = IProcess.class, property = 
"de.uniaugsburg.smds.aadl2osgi.component.uid=test.Process1")

public class Process1 implements IProcess {

 @Reference(target = "(uid=test.Thread1_1)")
 private volatile IPeriodicThread thread1;

 @Reference(target = "(uid=test.Thread1_2)")
 private volatile IPeriodicThread thread2;
}


@Component(service = IPeriodicThread.class, property = 
"de.uniaugsburg.smds.aadl2osgi.component.uid=test.Thread1_1", immediate 
= true)

public class Thread1_1 implements IPeriodicThread {

 @Reference(target = "(uid=test.OutDataPort1)")
 private volatile IOutDataPort outport;

 @Activate
 public void initialize_FW() {
   init();
 }

 @Deactivate
 public void finalize_FW() {
   deinit();
 }
}


@Component(service = IPeriodicThread.class, property = 
"de.uniaugsburg.smds.aadl2osgi.component.uid=test.Thread1_2", immediate 
= true)

public class Thread1_2 implements IPeriodicThread {

 @Reference(target = "(uid=test.InDataPort1)")
 private volatile IOutDataPort outport;

 @Activate
 public void initialize_FW() {
   init();
 }

 @Deactivate
 public void finalize_FW() {
   deinit();
 }
}


@Component(service = IOutDataPort.class, property = 
"uid=test.OutDataPort1", immediate = true)

public class OutDataPort1 implements IOutDataPort {

 @Reference(target = "(target=test.OutDataPort1)", cardinality = 
ReferenceCardinality.OPTIONAL, policyOption = 
ReferencePolicyOption.GREEDY)

 private volatile IPortConnection incomingPortConnections;

 private volatile Set outgoingPortConnections = new 
ConcurrentSkipListSet();


 @Reference(target = "(source=test.OutDataPort1)", cardinality = 
ReferenceCardinality.OPTIONAL, policyOption = 
ReferencePolicyOption.GREEDY)

 public void addOutgoingPortConnection(final IPortConnection con) {
   outgoingPortConnections.add(con);
 }

 public void removeOutgoingPortConnection(final IPortConnection con) {
   outgoingPortConnections.remove(con);
 }
}


@Component(service = IInDataPort.class, property = 
"uid=test.InDataPort1", immediate = true)

@SuppressWarnings("all")
public class InDataPort1 implements IInDataPort {

 @Reference(target = "(target=test.InDataPort1)", cardinality = 
ReferenceCardinality.OPTIONAL, policyOption = 
ReferencePolicyOption.GREEDY)

 private volatile IPortConnection incomingPortConnections;

 private volatile Set outgoingPortConnections = new 
ConcurrentSkipListSet();


 @Reference(target = "(source=test.InDataPort1)", cardinality = 
ReferenceCardinality.OPTIONAL, policyOption = 
ReferencePolicyOption.GREEDY)

 public void addOutgoingPortConnection(final IPortConnection con) {
   outgoingPortConnections.add(con);
 }

 public void removeOutgoingPortConnection(final IPortConnection con) {
   outgoingPortConnections.remove(con);
 }
}


@Component(service = IPortConnection.class, property = { 
"source=test.OutDataPort1", "target=test.InDataPort1" }, immediate = 
true)

public class Con1 implements IPortConnection {
 @Reference(cardinality = ReferenceCardinality.OPTIONAL, policyOption = 
ReferencePolicyOption.GREEDY, target = "(uid=test.OutDataPort1)")

 private volatile IOutDataPort source;

 @Reference(cardinality = ReferenceCardinality.OPTIONAL, policyOption = 
ReferencePolicyOption.GREEDY, target = "(uid=test.InDataPort1)")

 private volatile IInDataPort target;
}___
OSGi Developer Mail List
osgi-dev@mail.osgi.org
https://mail.osgi.org/mailman/listinfo/osgi-dev

Re: [osgi-dev] osgi broker bundle

2017-02-17 Thread chris . gray
If you really only need MQTT then I think you should be looking at a
dedicated MQTT broker rather than an all-singing, all-dancing message
boroker like ActiveMQ. Moquette looks promising (caveat - I haven't tried
it. yet)

> Hi guys,
>
> I'm looking on how deploying an MQTT broker into an osgi environment.
>
> I'm running my osgi container in an embedded environment.
>
> I tried installing apache Karaf as it already has the ActiveMQ broker
> integration easy, but i was not able to install it as it needs some junit
> libraries that does not comply with the jre embedded.
>
> The other solution I'm thinking of is installing the ActiveMQ broker
> against Felix.
>
> I found in an mvn repo an osgi bundle for the activeMQ but it needs its
> dependencies.
>
> So I tried adding them as bundles but I faced an issue right now because
> when I start that bundle it asks for a dependency that I can't find it.
>
> ->  Unable to resolve org.apache.activemq.activemq-osgi version=5.14.3:
>missing requirement org.osgi.service.blueprint; version=[1.0.0,2.0.0)]
>
> Do you have an idea on how I have to proceed ?
>
> Thanks in advance :)
> Meher
> ___
> 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 broker bundle

2017-02-17 Thread BJ Hargrave
Sounds like it wants Blueprint. Maybe just the API package, maybe the implementation. I would not expect a Blueprint implementation to run in jre embedded.
 
Have you looked at https://projects.eclipse.org/projects/technology.mosquitto ?
--BJ HargraveSenior Technical Staff Member, IBM // office: +1 386 848 1781OSGi Fellow and CTO of the OSGi Alliance // mobile: +1 386 848 3788hargr...@us.ibm.com
 
 
- Original message -From: Mestiri Meher Sent by: osgi-dev-boun...@mail.osgi.orgTo: OSGi Developer Mail List Cc:Subject: [osgi-dev] osgi broker bundleDate: Fri, Feb 17, 2017 11:29 AM 
Hi guys,
 
I'm looking on how deploying an MQTT broker into an osgi environment.
 
I'm running my osgi container in an embedded environment.
 
I tried installing apache Karaf as it already has the ActiveMQ broker integration easy, but i was not able to install it as it needs some junit libraries that does not comply with the jre embedded.
 
The other solution I'm thinking of is installing the ActiveMQ broker against Felix.
 
I found in an mvn repo an osgi bundle for the activeMQ but it needs its dependencies.
 
So I tried adding them as bundles but I faced an issue right now because when I start that bundle it asks for a dependency that I can't find it.
 
->  Unable to resolve org.apache.activemq.activemq-osgi version=5.14.3:
   missing requirement org.osgi.service.blueprint; version=[1.0.0,2.0.0)]
 
Do you have an idea on how I have to proceed ?
 
Thanks in advance :)
Meher
___OSGi Developer Mail Listosgi-dev@mail.osgi.orghttps://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-dev] osgi broker bundle

2017-02-17 Thread Mestiri Meher
Hi guys,

I'm looking on how deploying an MQTT broker into an osgi environment.

I'm running my osgi container in an embedded environment.

I tried installing apache Karaf as it already has the ActiveMQ broker
integration easy, but i was not able to install it as it needs some junit
libraries that does not comply with the jre embedded.

The other solution I'm thinking of is installing the ActiveMQ broker
against Felix.

I found in an mvn repo an osgi bundle for the activeMQ but it needs its
dependencies.

So I tried adding them as bundles but I faced an issue right now because
when I start that bundle it asks for a dependency that I can't find it.

->  Unable to resolve org.apache.activemq.activemq-osgi version=5.14.3:
   missing requirement org.osgi.service.blueprint; version=[1.0.0,2.0.0)]

Do you have an idea on how I have to proceed ?

Thanks in advance :)
Meher
___
OSGi Developer Mail List
osgi-dev@mail.osgi.org
https://mail.osgi.org/mailman/listinfo/osgi-dev