ActiveMq mit Mqtt im Glassfishserver

[JurijJunge]

Hi ich habe einen ActiveMq Broker in meinen Glassfishserver deployed. Ich möchte nun, dass der Broker über Mqtt kommuniziert. Ich habe einen paho mqtt client den ich nutzen will. Im Ressource Adapter für ActiveMq habe ich folgende Einstellungen:
ServerUrl:vm://0.0.0.0:61616
BrokerXMLConfig:brokertcp://0.0.0.0:1883)

In der broker-config xml steht:

    <transportConnectors>
      <transportConnector name="openwire" uri="tcp://localhost:61616"/>
     <transportConnector name="mqtt" uri="mqtt+nio://0.0.0.0:1883"/> 
    </transportConnectors>

und in der ra.xml habe ich:

        <config-property>
            <description>
              The URL to the ActiveMQ server that you want this connection to connect to.  If using
              an embedded broker, this value should be 'vm://localhost'.
            </description>
            <config-property-name>ServerUrl</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
            <!--<config-property-value>tcp://localhost:61616</config-property-value>-->
            <config-property-value>vm://localhost</config-property-value>
        </config-property>

       <config-property>
            <description>
              Sets the XML configuration file used to configure the embedded ActiveMQ broker via
              Spring if using embedded mode.
            
              BrokerXmlConfig is the filename which is assumed to be on the classpath unless
              a URL is specified. So a value of foo/bar.xml would be assumed to be on the
              classpath whereas file:dir/file.xml would use the file system.
              Any valid URL string is supported.             
            </description>
            <config-property-name>BrokerXmlConfig</config-property-name>
            <config-property-type>java.lang.String</config-property-type>
            <config-property-value></config-property-value>
            <!--
             To use the broker-config.xml from the root for the RAR-->
               <!--<config-property-value>xbean:broker-config.xml</config-property-value>-->
             <!--To use an external file or url location
               <config-property-value>xbean:file:///amq/config/jee/broker-config.xml</config-property-value>
            -->
        </config-property>

Bei der configproperty BrokerXmlConfig würde ich eigentlich auf <config-property-value>xbean:broker-config.xml</config-property-value> stellen, aber danach funktioniert der Broker nicht mehr richtig. Kann mir jemand bei den Einstellungen helfen? Ich will mqtt über den Port 1883 erreichen.
Der Testcode für den Client ist:

    public static void main(String[] args) {
        String topic = "MQTT Examples";
        String content = "Message from MqttPublishSample";
        int qos = 2;
        String broker = "tcp://localhost:1883";
        String clientId = "JavaSample";
        MemoryPersistence persistence = new MemoryPersistence();
       
        try

        {
            MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
            sampleClient.setTimeToWait(5000);
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            System.out.println("Connecting to broker: " + broker);
            sampleClient.connect(connOpts);
            System.out.println("Connected");
            System.out.println("Publishing message: " + content);
            MqttMessage message = new MqttMessage(content.getBytes());
            message.setQos(qos);
            sampleClient.publish(topic, message);
            System.out.println("Message published");
            sampleClient.disconnect();
            System.out.println("Disconnected");
            System.exit(0);
        } catch (

        MqttException me)

        {
            System.out.println("reason " + me.getReasonCode());
            System.out.println("msg " + me.getMessage());
            System.out.println("loc " + me.getLocalizedMessage());
            System.out.println("cause " + me.getCause());
            System.out.println("excep " + me);
            me.printStackTrace();
        }
    }

Danke für die Hilfe im vorraus