@ManagedResource(description="IMAP Agent") public class IMAPAgent extends Object implements org.springframework.jmx.export.naming.SelfNaming, org.springframework.context.Lifecycle, org.springframework.beans.factory.InitializingBean
Constructor and Description |
---|
IMAPAgent() |
Modifier and Type | Method and Description |
---|---|
void |
acquireLock()
Acquire the permission to start an email conversion.
|
void |
afterPropertiesSet() |
List<IMAPPickupConfiguration> |
getConfigurations() |
int |
getMaxConcurrentJobCount() |
int |
getNumberOfWaitingThreads()
Number of threads waiting for a lock to acquire.
|
ObjectName |
getObjectName() |
boolean |
isRunning() |
void |
jmxStart() |
void |
jmxStop() |
void |
releaseLock()
Must be called the an email conversion has finished (whether successful or not)
|
void |
setConfigurations(List<IMAPPickupConfiguration> configurations) |
void |
setMaxConcurrentJobCount(int maxConcurrentJobCount) |
void |
start() |
void |
stop() |
public void start()
start
in interface org.springframework.context.Lifecycle
@ManagedOperation(description="Start the IMAP Agent") public void jmxStart()
public void stop()
stop
in interface org.springframework.context.Lifecycle
@ManagedOperation(description="Stop the IMAP Agent") public void jmxStop()
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
Exception
@ManagedAttribute(description="Check if the IMAP Agent is up and running") public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
@ManagedAttribute(description="Number of waiting threads. Should usually be zero") public int getNumberOfWaitingThreads()
getNumberOfWaitingThreads()
public ObjectName getObjectName() throws MalformedObjectNameException
getObjectName
in interface org.springframework.jmx.export.naming.SelfNaming
MalformedObjectNameException
public List<IMAPPickupConfiguration> getConfigurations()
public void setConfigurations(List<IMAPPickupConfiguration> configurations)
public int getMaxConcurrentJobCount()
public void setMaxConcurrentJobCount(int maxConcurrentJobCount)
public void acquireLock() throws InterruptedException
InterruptedException
getMaxConcurrentJobCount()
public void releaseLock()
Copyright © 2017 levigo holding gmbh. All rights reserved.