Package com.sun.messaging.jmq.jmsserver.service.imq

Examples of com.sun.messaging.jmq.jmsserver.service.imq.IMQConnection.destroyConnection()

126
127
128
129
130
131
132
133
134
135
136
                                new ConnectionUID(cxnId.longValue()));
                if (cxn != null) {
                    if (DEBUG) {
                        cxn.dump();
                    }
                    cxn.destroyConnection(true, GoodbyeReason.ADMIN_KILLED_CON,
                       Globals.getBrokerResources().getKString(
                       BrokerResources.M_ADMIN_REQ_CLOSE));
                } else {
                    status = Status.NOT_FOUND;
                    errMsg = rb.getString(rb.E_NO_SUCH_CONNECTION,
View Full Code Here
707
708
709
710
711
712
713
714
715
716
717
                    ConnectionUID uid = new ConnectionUID(
                        Long.parseLong(target));
                    IMQConnection cxn = (IMQConnection)
                        Globals.getConnectionManager()
                                .getConnection(uid);
                    cxn.destroyConnection(true, GoodbyeReason.ADMIN_KILLED_CON,
                            "kill cnx");

                } catch (Exception ex) {
                    status = Status.ERROR;
                    msg = "Error killing connection  " + target +
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
                logger.log(Logger.DEBUG,"Can't get reason string for destroying connection " + uid);
            }
            if (reason == null) reason = "REASON NOTFOUND";
            if (con != null && con.isValid()) {
                try {
                    con.destroyConnection(false,GoodbyeReason.CLIENT_CLOSED, reason);
                } catch (Exception ex) {
                    logger.logStack(Logger.DEBUG,"error destroying connection " + con , ex);
                }
            }
            itr.remove();
View Full Code Here
237
238
239
240
241
242
243
244
245
246
247
                logger.log(Logger.DEBUG,"Can't get reason string for destroying connection " + uid);
            }
            if (reason == null) reason = "REASON NOTFOUND";
            if (con != null && con.isValid()) {
                try {
                    con.destroyConnection(false,GoodbyeReason.CLIENT_CLOSED, reason);
                } catch (Exception ex) {
                    logger.logStack(Logger.DEBUG,"error destroying connection " + con , ex);
                }
            }
            itr.remove();
View Full Code Here
226
227
228
229
230
231
232
233
234
235
236
  IMQConnection    cxn = null;

  cxn = (IMQConnection)cm.getConnection(new ConnectionUID(cxnId));

  if (cxn != null)  {
      cxn.destroyConnection(true, GoodbyeReason.ADMIN_KILLED_CON,
            reasonString);
  }
    }

    public static void destroyConnection(String serviceName, String reasonString)  {
View Full Code Here
248
249
250
251
252
253
254
255
256
257
258
        while (iter.hasNext()) {
      cxn     = (IMQConnection)iter.next();

      if (cxn != null)  {
          cxn.destroyConnection(true, GoodbyeReason.ADMIN_KILLED_CON,
            reasonString);
      }
        }
    }
}
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.