this.factory = factory;
connection = (ActiveMQConnection) factory.createConnection();
connection.start();
anonymousPublisher = new ActiveMQPublisherRegistration(connection);
NotificationBrokerRPDocument document = NotificationBrokerRPDocument.Factory.newInstance();
resourceProperties = document.addNewNotificationBrokerRP();
resourceProperties.setFixedTopicSet(false);
resourceProperties.setRequiresRegistration(false);
resourceProperties.setTopicExpressionDialectsArray(new String[]{"ActiveMQ"});
xmlResourceProperties = new XmlObjectResourceProperties(resourceProperties);
}