public class DirectoryResenderModule extends BaseResenderModule
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_RESEND_DELAY |
static String |
PARAM_ERROR_DIRECTORY |
static String |
PARAM_RESEND_DELAY |
static String |
PARAM_RESEND_DIRECTORY |
TICK_INTERVAL
DO_RESEND, DO_RESENDMDN, OPTION_CAUSE, OPTION_INITIAL_SENDER, OPTION_RESEND_METHOD, OPTION_RETRIES
Constructor and Description |
---|
DirectoryResenderModule() |
Modifier and Type | Method and Description |
---|---|
boolean |
canHandle(String action,
Message msg,
Map<Object,Object> options) |
protected String |
getFilename() |
void |
handle(String action,
Message msg,
Map<Object,Object> options) |
boolean |
healthcheck(List<String> failures)
When invoked, the module must run a self check to verify it is functioning correctly.
|
void |
init(Session session,
Map<String,String> options)
Component lifecycle hook.
|
protected boolean |
isTimeToSend(File currentFile) |
protected void |
processFile(File file) |
void |
resend() |
protected List<File> |
scanDirectory() |
doStart, doStop
forceStop, isRunning, start, stop, toString
destroy, getName, getParameter, getParameter, getParameterInt, getParameters, getSession, setParameter, setParameter
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
destroy, getName, getParameters, getSession
public static final String PARAM_RESEND_DIRECTORY
public static final String PARAM_ERROR_DIRECTORY
public static final String PARAM_RESEND_DELAY
public static final long DEFAULT_RESEND_DELAY
public boolean canHandle(String action, Message msg, Map<Object,Object> options)
canHandle
in interface ProcessorModule
canHandle
in class BaseActiveModule
public void handle(String action, Message msg, Map<Object,Object> options) throws OpenAS2Exception
handle
in interface ProcessorModule
handle
in class BaseActiveModule
OpenAS2Exception
public void init(Session session, Map<String,String> options) throws OpenAS2Exception
Component
init
in interface Component
init
in class BaseComponent
session
- the component uses this object to access other componentsoptions
- configuration values for the componentOpenAS2Exception
- If an error occurs while initializing the componentSession
public void resend()
resend
in class BaseResenderModule
public boolean healthcheck(List<String> failures)
ActiveModule
healthcheck
in interface ActiveModule
healthcheck
in class BaseActiveModule
failures
- - a list of failures if any occurprotected String getFilename() throws InvalidParameterException
InvalidParameterException
protected boolean isTimeToSend(File currentFile)
protected void processFile(File file) throws OpenAS2Exception
OpenAS2Exception
protected List<File> scanDirectory() throws OpenAS2Exception, IOException
OpenAS2Exception
IOException
Copyright © 2018. All rights reserved.