Connect jeromq-jms subscriber to zeroMQ Publisher about jeromq-jms HOT 4 CLOSED

On 21 Jan 2019, at 07:08, mueller-jens ***@***.***> wrote: I have overridden the ZmqConnectionFactory and the ZmQConnection to overcome this: ZmqConnectionFactory: public class ZmqConnectionFactory extends org.zeromq.jms.ZmqConnectionFactory { private final Map<String, ZmqURI> destinationSchema = new HashMap<String, ZmqURI>(); private String gatewayFactoryClassName = ZmqGatewayFactory.class.getCanonicalName(); private String[] packageNameExtensions = null; /** * Construct Zero MQ connection factory. */ public ZmqConnectionFactory() { super(); } /** * Construct Zero MQ connection factory with the specified destination URIs. * @param destinations the destination URIs */ public ZmqConnectionFactory(final String[] destinations) { super(destinations); } /** * Construct Zero MQ connection factory with the specified destination URIs. * @param gatewayFactoryClassName the class name of the gateway factory * @param packageNameExtensions the array of packages containing extension to ZERO MQ * @param destinations the destination URIs */ public ZmqConnectionFactory(final String gatewayFactoryClassName, final String[] packageNameExtensions, final String[] destinations) { super(gatewayFactoryClassName, packageNameExtensions, destinations); this.gatewayFactoryClassName = gatewayFactoryClassName; this.packageNameExtensions = packageNameExtensions; } /** * @return return a factory gateway * @throws ZmqException throws exception when factory construction fails */ private ZmqGatewayFactory getFactoryGateway() throws ZmqException { try { @SuppressWarnings("unchecked") final Class<? extends ZmqGatewayFactory> gatewayFactoryClass = (Class<? extends ZmqGatewayFactory>) Class .forName(gatewayFactoryClassName); final Constructor<?> gatewayFactoryConstructor = gatewayFactoryClass.getConstructor(String[].class, Map.class); final ZmqGatewayFactory gatewayFactory = (ZmqGatewayFactory) gatewayFactoryConstructor.newInstance(packageNameExtensions, destinationSchema); return gatewayFactory; } catch (ClassNotFoundException ex) { throw new ZmqException("Class could not be found.", ex); } catch (NoSuchMethodException | SecurityException ex) { throw new ZmqException("Unable to find required constructor for class: " + gatewayFactoryClassName, ex); } catch (InstantiationException | IllegalAccessException | IllegalArgumentException | InvocationTargetException ex) { throw new ZmqException("Unable to invoke constructor for class: " + gatewayFactoryClassName, ex); } } @OverRide public QueueConnection createQueueConnection(final String userName, final String password) throws JMSException { ZmqGatewayFactory gatewayFactory = getFactoryGateway(); QueueConnection connection = new ZmqConnection(gatewayFactory, destinationSchema); return connection; } @OverRide public TopicConnection createTopicConnection() throws JMSException { return createTopicConnection(null, null); } @OverRide public TopicConnection createTopicConnection(final String userName, final String password) throws JMSException { ZmqGatewayFactory gatewayFactory = getFactoryGateway(); TopicConnection connection = new ZmqConnection(gatewayFactory, destinationSchema); return connection; } @OverRide public JMSContext createContext() { return createContext(null, null, ZmqSession.AUTO_ACKNOWLEDGE); } @OverRide public JMSContext createContext(final int sessionMode) { return createContext(null, null, sessionMode); } @OverRide public JMSContext createContext(final String userName, final String password) { return createContext(userName, password, ZmqSession.AUTO_ACKNOWLEDGE); } @OverRide public JMSContext createContext(final String userName, final String password, final int sessionMode) { try { ZmqGatewayFactory gatewayFactory = getFactoryGateway(); ZmqConnection connection = new ZmqConnection(gatewayFactory, destinationSchema); ZmqJMSContext context = new ZmqJMSContext(connection, sessionMode); return context; } catch (ZmqException ex) { throw new JMSRuntimeException("Unable to create context.", ex.getErrorCode(), ex); } } ZmqConnection: public class ZmqConnection extends org.zeromq.jms.ZmqConnection { public ZmqConnection(ZmqGatewayFactory gatewayFactory, Map<String, ZmqURI> destinationSchema) { super(gatewayFactory, destinationSchema); // } @OverRide public void start() throws JMSException { } @OverRide public void stop() throws JMSException { } @OverRide public void close() throws JMSException { } } — You are receiving this because you commented. Reply to this email directly, view it on GitHub <#14 (comment)>, or mute the thread <https://github.com/notifications/unsubscribe-auth/AHOnwIyZ7JFjn_-OAksoQj8gKfwxg-uzks5vFWdtgaJpZM4aIWK6>.