this.brokerManager = brokerManager;
URI uri = URI.create(component.getURI() + "/" + notificationBinding.getName());
notificationBinding.setURI(uri.toString());
Interface interfaze = reference.getInterfaceContract().getInterface();
interfaze.resetDataBinding(OMElement.class.getName());
for (Operation operation : interfaze.getOperations()) {
operation.setNonBlocking(false);
}
this.subscribers = new ArrayList<SubscriberInfo>();