org.apache.logging.log4j.core.net.server

Class JmsServer

java.lang.Object

org.apache.logging.log4j.core.LogEventListener

org.apache.logging.log4j.core.net.server.JmsServer

All Implemented Interfaces:

EventListener, javax.jms.MessageListener, LifeCycle, LifeCycle2

public class JmsServer
extends LogEventListener
implements javax.jms.MessageListener, LifeCycle2

LogEventListener server that receives LogEvents over a JMS Destination.

Since:

2.1

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.logging.log4j.core.LifeCycle

LifeCycle.State

Field Summary

Fields inherited from class org.apache.logging.log4j.core.LogEventListener

LOGGER

Constructor Summary

Constructors

Constructor and Description
JmsServer(String connectionFactoryBindingName, String destinationBindingName, String username, String password)

Method Summary

Modifier and Type	Method and Description
LifeCycle.State	getState() Gets the life-cycle state.
void	initialize()
boolean	isStarted()
boolean	isStopped()
void	onMessage(javax.jms.Message message)
void	run() Starts and runs this server until the user types "exit" into standard input.
void	start()
void	stop()
boolean	stop(long timeout, TimeUnit timeUnit) Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Methods inherited from class org.apache.logging.log4j.core.LogEventListener

log

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JmsServer

public JmsServer(String connectionFactoryBindingName,
                 String destinationBindingName,
                 String username,
                 String password)

Method Detail

getState

public LifeCycle.State getState()

Description copied from interface: LifeCycle

Gets the life-cycle state.

Specified by:

getState in interface LifeCycle

Returns:

the life-cycle state

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

initialize

public void initialize()

Specified by:

initialize in interface LifeCycle

start

public void start()

Specified by:

start in interface LifeCycle

stop

public void stop()

Specified by:

stop in interface LifeCycle

stop

public boolean stop(long timeout,
                    TimeUnit timeUnit)

Description copied from interface: LifeCycle2

Blocks until all tasks have completed execution after a shutdown request, or the timeout occurs, or the current thread is interrupted, whichever happens first.

Specified by:

stop in interface LifeCycle2

Parameters:

timeout - the maximum time to wait

timeUnit - the time unit of the timeout argument

Returns:

true if the receiver was stopped cleanly and normally, false otherwise.

isStarted

public boolean isStarted()

Specified by:

isStarted in interface LifeCycle

isStopped

public boolean isStopped()

Specified by:

isStopped in interface LifeCycle

run

public void run()
         throws IOException

Starts and runs this server until the user types "exit" into standard input.

Throws:

IOException

Since:

2.6