1 18 package org.apache.activemq.transport; 19 20 21 22 28 public abstract class TransportThreadSupport extends TransportSupport implements Runnable { 29 30 private boolean daemon = false; 31 private Thread runner; 32 private long stackSize=0; 34 public boolean isDaemon() { 35 return daemon; 36 } 37 38 public void setDaemon(boolean daemon) { 39 this.daemon = daemon; 40 } 41 42 protected void doStart() throws Exception { 43 runner = new Thread (null,this, "ActiveMQ Transport: "+toString(),stackSize); 44 runner.setDaemon(daemon); 45 runner.start(); 46 } 47 48 49 52 public long getStackSize(){ 53 return this.stackSize; 54 } 55 56 57 60 public void setStackSize(long stackSize){ 61 this.stackSize=stackSize; 62 } 63 } 64 | Popular Tags |