- public void setAgentDestinationPrefix(String agentDestinationPrefix) {
- this.agentDestinationPrefix = agentDestinationPrefix;
+ public void onMessage(Message message) {
+ // FIXME: we filter the messages on the client side,
+ // because of a weird problem with selector since moving to OSGi
+ try {
+ if (message.getStringProperty("slc-agentId").equals(
+ agentDescriptor.getUuid())) {
+ runSlcExecution((SlcExecution) messageConverter
+ .fromMessage(message));
+ }
+ } catch (JMSException e) {
+ throw new SlcException("Cannot convert message " + message, e);
+ }
+