Package org.hornetq.core.client.impl

Examples of org.hornetq.core.client.impl.ServerLocatorInternal.connect()

249
250
251
252
253
254
255
256
257
258
259
                  {
                     HornetQServerLogger.LOGGER.debug(BackupConnector.this + ":: announcing " + connector + " to " + backupServerLocator);
                  }
                  announcingBackup = true;
                  //connect to the cluster
                  ClientSessionFactory backupSessionFactory = localBackupLocator.connect();
                  //send the announce message
                  if (backupSessionFactory != null)
                  {
                     backupSessionFactory.getConnection()
                           .getChannel(0, -1)
View Full Code Here
532
533
534
535
536
537
538
539
540
541
542
               if (HornetQServerLogger.LOGGER.isDebugEnabled())
               {
                  HornetQServerLogger.LOGGER.debug(ClusterConnectionImpl.this + ":: announcing " + connector + " to " + backupServerLocator);
               }
               announcingBackup = true;
               ClientSessionFactory backupSessionFactory = localBackupLocator.connect();
               if (backupSessionFactory != null)
               {
                  backupSessionFactory.getConnection()
                                      .getChannel(0, -1)
                                      .send(new NodeAnnounceMessage(System.currentTimeMillis(),
View Full Code Here
533
534
535
536
537
538
539
540
541
542
543
               if (HornetQServerLogger.LOGGER.isDebugEnabled())
               {
                  HornetQServerLogger.LOGGER.debug(ClusterConnectionImpl.this + ":: announcing " + connector + " to " + backupServerLocator);
               }
               announcingBackup = true;
               ClientSessionFactory backupSessionFactory = localBackupLocator.connect();
               if (backupSessionFactory != null)
               {
                  backupSessionFactory.getConnection()
                                      .getChannel(0, -1)
                                      .send(new NodeAnnounceMessage(System.currentTimeMillis(),
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
   }

   public void testSingleConnectorSingleServerConnect() throws Exception
   {
      ServerLocatorInternal locator = (ServerLocatorInternal) HornetQClient.createServerLocatorWithoutHA(createTransportConfiguration(isNetty(), false, generateParams(0, isNetty())));
      ClientSessionFactoryInternal csf = (ClientSessionFactoryInternal) locator.connect();
      assertNotNull(csf);
      assertEquals(csf.numConnections(), 1);
      locator.close();
   }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
            createTransportConfiguration(isNetty(), false, generateParams(1, isNetty())),
            createTransportConfiguration(isNetty(), false, generateParams(2, isNetty())),
            createTransportConfiguration(isNetty(), false, generateParams(3, isNetty())),
            createTransportConfiguration(isNetty(), false, generateParams(4, isNetty()))
      );
      ClientSessionFactoryInternal csf = (ClientSessionFactoryInternal) locator.connect();
      assertNotNull(csf);
      assertEquals(csf.numConnections(), 1);
      locator.close();
   }
View Full Code Here
93
94
95
96
97
98
99
100
101
102
103
            createTransportConfiguration(isNetty(), false, generateParams(2, isNetty())),
            createTransportConfiguration(isNetty(), false, generateParams(3, isNetty())),
            createTransportConfiguration(isNetty(), false, generateParams(4, isNetty()))
      );
      locator.setReconnectAttempts(-1);
      ClientSessionFactoryInternal csf = (ClientSessionFactoryInternal) locator.connect();
      assertNotNull(csf);
      assertEquals(csf.numConnections(), 1);
      locator.close();
   }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
            createTransportConfiguration(isNetty(), false, generateParams(5, isNetty()))
      );
      ClientSessionFactoryInternal csf = null;
      try
      {
         csf = (ClientSessionFactoryInternal) locator.connect();
      }
      catch (Exception e)
      {
         assertTrue(e instanceof HornetQException);
         assertEquals(((HornetQException)e).getCode(), HornetQException.NOT_CONNECTED);
View Full Code Here
534
535
536
537
538
539
540
541
542
543
544
               if (HornetQServerLogger.LOGGER.isDebugEnabled())
               {
                  HornetQServerLogger.LOGGER.debug(ClusterConnectionImpl.this + ":: announcing " + connector + " to " + backupServerLocator);
               }
               announcingBackup = true;
               ClientSessionFactory backupSessionFactory = localBackupLocator.connect();
               if (backupSessionFactory != null)
               {
                  backupSessionFactory.getConnection()
                                      .getChannel(0, -1)
                                      .send(new NodeAnnounceMessage(System.currentTimeMillis(),
View Full Code Here
2432
2433
2434
2435
2436
2437
2438
2439
2440
2441
2442
               configuration.getFailBackConnectors().toArray(new TransportConfiguration[1]);
            locator = (ServerLocatorInternal)HornetQClient.createServerLocatorWithHA(tpArray);
            locator.setReconnectAttempts(0);
            try
            {
               factory = locator.connect();
            }
            catch (HornetQNotConnectedException notConnected)
            {
               return false;
            }
View Full Code Here
508
509
510
511
512
513
514
515
516
517
518
               if (HornetQLogger.LOGGER.isDebugEnabled())
               {
                  HornetQLogger.LOGGER.debug(ClusterConnectionImpl.this + ":: announcing " + connector + " to " + backupServerLocator);
               }
               announcingBackup = true;
               ClientSessionFactory backupSessionFactory = localBackupLocator.connect();
               if (backupSessionFactory != null)
               {
                  backupSessionFactory.getConnection()
                                      .getChannel(0, -1)
                                      .send(new NodeAnnounceMessage(System.currentTimeMillis(),
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.