3

組み込みHornetQコアの例に従って、OSGIコンテナーで組み込みHornetQサーバーを実行しています。

私は3つのOSGIコンテナーを持っています。1つはサーバー用、1つはプロデューサー用、最後の1つはコンシューマー用です。すべてがローカルで動作します。

サーバーに接続するためにプロデューサーとコンシューマーの両方で使用しているコードは次のとおりです。

// Step 4. As we are not using a JNDI environment we instantiate the objects directly
ServerLocator serverLocator = HornetQClient.createServerLocatorWithoutHA(new TransportConfiguration(NettyConnectorFactory.class.getName()));
ClientSessionFactory sf = serverLocator.createSessionFactory();

メソッドを調べてみましTransportConfigurationたが、セッターが見つかりませんでした。

4

1 に答える 1

2

トランスポート構成にパラメーターを渡す必要があります。

Map<String, Object> parameters = new HashMap<String, Object>();
parameters.put("port", org.hornetq.core.remoting.impl.netty.TransportConstants
                      .DEFAULT_PORT);
parameters.put(TransportConstants.HOST_PROP_NAME, "127.0.0.1");

TransportConfiguration configuration = new TransportConfiguration(
        NettyConnectorFactory.class.getName(), parameters);

に同じことができる/できることに注意してくださいNettyAcceptor。テストでアクセプターをどのように構成しているかはわかりませんが、理解していただければ幸いです。

于 2012-10-03T16:13:48.087 に答える