client à distance file d'attente JMS

J'ai une file d'attente JMS configuré à distance sur serveur glassfish. J'essaie de connecter cette file d'attente à partir de ma machine locale. Est-il possible de se connecter directement à ce serveur ou j'ai besoin de vous connecter via un courtier/agent? Comment ça fonctionne? (Je suis frais dans jms zone)
Merci beaucoup

InformationsquelleAutor speedingdeer | 2013-06-24
  1. 11

    Si votre client demande est en cours d'exécution à l'extérieur de Glassfish voici un exemple de code simple pour un client mq.

    À le faire fonctionner, vous aurez besoin de faire référence à 2 openmq pots du glassfishInstall/mq/lib - imq.jar et jms.jar

    import com.sun.messaging.ConnectionConfiguration;
import com.sun.messaging.ConnectionFactory;
import com.sun.messaging.Queue;
import javax.jms.Connection;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Session;

public class TestJmsClientStandalone2 {

    public static void main( String[] args ) throws JMSException
    {
        ConnectionFactory connFactory = new ConnectionFactory();
        connFactory.setProperty(ConnectionConfiguration.imqAddressList, "remotehostip:7676");

        Queue myQueue = new Queue("myRemoteQueue");

        try (Connection connection = connFactory.createConnection(); 
                Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
                MessageProducer producer = session.createProducer(myQueue)) {

            Message message = session.createTextMessage("this is my test message");
            producer.send(message);
        }
    }
}
    InformationsquelleAutor Stewart Evans
  2. 6

    Est votre client demande l'exécution dans un local glassfish instance et d'essayer de se connecter à distance glassfish instance de ressources JMS?

    Si oui, alors j'ai trouvé 2 façons de le faire. Pour les deux options, configurer de la même usine de raccordement et de destination (file d'attente) des Ressources JMS dans le local et distant glassfish instances.

    1) Définir la fabrique de connexions jms propriété "addressList"

    Dans les clients à la console d'administration de glassfish aller à Resources->JMS Resources->Connection Factories->jms/YourConnectionFactory->Additional Properties

    Ajouter une propriété supplémentaire avec le nom addressList et la valeur XX.XX.XX.XX:AAAA
    lorsque la valeur est l'adresse IP de la machine distante et le numéro de port du service JMS est en cours d'exécution sur.

    ou

    2) Définir le client glassfish Java Message Service pour se connecter à la télécommande glassfish

    Dans les clients à la console d'administration de glassfish aller àConfigurations->server-config->Java Message Service

    • Ensemble JMS Type de Service à DISTANCE: (cliquez sur enregistrer)
    • Ensemble JMS Hosts->default_JMS_host Adresse IP et un port à l'Adresse IP et le port de la distance glassfish service JMS

    J'ai testé les deux options pour travailler avec Glassfish 4. Espérons que cela aide.

    InformationsquelleAutor Stewart Evans
  3. 4

    Je n'ai aucune expérience avec Glassfish, mais ce scénario ne fonctionne pas avec JBoss (qui intègre JBossMQ), et il devrait être généralement applicables ainsi:

    Serveur:

    • Configuration du serveur: Créer une file d'attente, et le lier à un nom pour être visible dans JNDI
    • De configuration du serveur: assurez-vous que la connexion de l'usine est visible dans JNDI ainsi

    Client:

    • De recherche de la fabrique de connexions et la file d'attente en utilisant JNDI. Cette possibilité nécessite certaines valeurs à mettre dans les propriétés pour le InitialContext
    • Sur le dessus de la connexion de l'usine et de la file d'attente, vous pouvez construire les autres objets (la file d'attente de connexion/session/récepteur).

    Comme pour JBoss, il ressemble à ceci:

        final Properties initialContextProperties = new Properties();
    initialContextProperties.put("java.naming.factory.initial",
            "org.jnp.interfaces.NamingContextFactory");
    initialContextProperties.put("java.naming.provider.url",
            "jnp://localhost:1099");

    //

    final InitialContext ic = new InitialContext(initialContextProperties);

    final QueueConnectionFactory qcf = (QueueConnectionFactory) ic
            .lookup("XAConnectionFactory");
    final Queue queue = (Queue) ic.lookup("queue/A");

    De sorte que le courtier ou l'agent de passer par est JNDI.

    InformationsquelleAutor Beryllium