001/**
002 * Licensed to the Apache Software Foundation (ASF) under one or more
003 * contributor license agreements.  See the NOTICE file distributed with
004 * this work for additional information regarding copyright ownership.
005 * The ASF licenses this file to You under the Apache License, Version 2.0
006 * (the "License"); you may not use this file except in compliance with
007 * the License.  You may obtain a copy of the License at
008 *
009 *      http://www.apache.org/licenses/LICENSE-2.0
010 *
011 * Unless required by applicable law or agreed to in writing, software
012 * distributed under the License is distributed on an "AS IS" BASIS,
013 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
014 * See the License for the specific language governing permissions and
015 * limitations under the License.
016 */
017package org.apache.activemq.transport;
018
019/**
020 * A useful base class for a transport implementation which has a background
021 * reading thread.
022 * 
023 * 
024 */
025public abstract class TransportThreadSupport extends TransportSupport implements Runnable {
026
027    private boolean daemon;
028    private Thread runner;
029    // should be a multiple of 128k
030    private long stackSize;
031
032    public boolean isDaemon() {
033        return daemon;
034    }
035
036    public void setDaemon(boolean daemon) {
037        this.daemon = daemon;
038    }
039
040    protected void doStart() throws Exception {
041        runner = new Thread(null, this, "ActiveMQ Transport: " + toString(), stackSize);
042        runner.setDaemon(daemon);
043        runner.start();
044    }
045
046    /**
047     * @return the stackSize
048     */
049    public long getStackSize() {
050        return this.stackSize;
051    }
052
053    /**
054     * @param stackSize the stackSize to set
055     */
056    public void setStackSize(long stackSize) {
057        this.stackSize = stackSize;
058    }
059}