Package org.apache.activemq.thread

Examples of org.apache.activemq.thread.TaskRunner.shutdown()

162
163
164
165
166
167
168
169
170
171
172
            } finally {
                stopping.set(false);
                enqueueValve.turnOn();
            }
            if (tr != null) {
                tr.shutdown(1000);
            }
        }
    }
   
    /**
 
View Full Code Here
176
177
178
179
180
181
182
183
184
185
186
            } finally {
                stopping.set(false);
                enqueueValve.turnOn();
            }
            if (tr != null) {
                tr.shutdown(1000);
            }
           

        }
       
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
            } finally {
                stopping.set(false);
                enqueueValve.turnOn();
            }
            if (tr != null) {
                tr.shutdown(1000);
            }
        }
    }
   
    /**
 
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
            // Allow pending deliveries to finish up, but don't wait
            // forever in case of an stalled onCommand.
            if (tr != null) {
                try {
                    tr.shutdown(TimeUnit.SECONDS.toMillis(1));
                } catch(Exception e) {
                }
            }

            // let the peer know that we are disconnecting after attempting
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
                        .createTaskRunner(task, name);
                if (name.startsWith("ActiveMQ Connection Dispatcher: ")) {
                    return new TaskRunner() {
                        @Override
                        public void shutdown() throws InterruptedException {
                            realTaskRunner.shutdown();
                        }

                        @Override
                        public void shutdown(long timeout)
                                throws InterruptedException {
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
                        }

                        @Override
                        public void shutdown(long timeout)
                                throws InterruptedException {
                            realTaskRunner.shutdown(timeout);
                        }

                        @Override
                        public void wakeup() throws InterruptedException {
                            Thread.sleep(taskRunnerDelay);
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
            } finally {
                stopping.set(false);
                enqueueValve.turnOn();
            }
            if (tr != null) {
                tr.shutdown(1000);
            }
           

        }
       
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
            } finally {
                stopping.set(false);
                enqueueValve.turnOn();
            }
            if (tr != null) {
                tr.shutdown(1000);
            }
           

        }
       
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
        log.info("counter: "+counter.get());
        log.info("Dequeues/s: "+(1000.0*ENQUEUE_COUNT/(end-start)));
        log.info("duration: "+((end-start)/1000.0));
        assertTrue(b);
       
        runner.shutdown();
    }
   
   
   
    public static void main(String[] args) {
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
            } finally {
                stopping.set(false);
                enqueueValve.turnOn();
            }
            if (tr != null) {
                tr.shutdown(1000);
            }
            // let the peer know that we are disconnecting..
            try {
                oneway(DISCONNECT);
            } catch (Exception ignore) {
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.