|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.util.protocol.RequestReplyExecutor org.xmlBlaster.util.protocol.email.EmailExecutor org.xmlBlaster.client.protocol.email.EmailConnection
public class EmailConnection
This driver sends emails to the xmlBlaster server, the return QOS are polled via POP3.
This "email" driver needs to be registered in xmlBlaster.properties and will be started on xmlBlaster startup:ClientProtocolPlugin[email][1.0]=org.xmlBlaster.client.protocol.email.EmailConnectionAll adjustable parameters are explained in
usage()
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.xmlBlaster.util.protocol.email.EmailExecutor |
---|
EmailExecutor.LoopProtection |
Field Summary | |
---|---|
private Global |
glob
|
private boolean |
isInitialized
|
private boolean |
isLoggedIn
|
private static java.util.logging.Logger |
log
|
protected java.lang.String |
loginName
|
private java.lang.String |
ME
|
private PluginInfo |
pluginInfo
|
private boolean |
stripSecurityQosCDATA
|
Fields inherited from class org.xmlBlaster.util.protocol.email.EmailExecutor |
---|
bcc, BOUNCE_MAILFROM_KEY, BOUNCE_MAILTO_KEY, BOUNCE_MESSAGEID_KEY, cc, fromAddress, messageIdFileName, msgInfoParserClassName, payloadFileNamePrefix, pop3Driver, senderLoopProtectionMap, smtpClient, SUBJECT_MESSAGEID_TOKEN, subjectTemplate, toAddress |
Fields inherited from class org.xmlBlaster.util.protocol.RequestReplyExecutor |
---|
addressConfig, addressServer, cbClient, compressZlib, compressZlibStream, contextNode, mbeanHandle, minSizeForCompression, ONEWAY, pingResponseTimeout, prefix, progressListener, responseListenerMap, responseTimeout, updateResponseTimeout, useEmailExpiryTimestamp, WAIT_ON_RESPONSE |
Constructor Summary | |
---|---|
EmailConnection()
Called by plugin loader which calls init(Global, PluginInfo) thereafter. |
Method Summary | |
---|---|
java.lang.String |
connect(java.lang.String connectQos)
Login to the server. |
void |
connectLowlevel(Address address)
Connects to xmlBlaster with one email connection. |
boolean |
disconnect(java.lang.String qos)
Does a logout and removes the callback server. |
java.lang.String[] |
erase(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Delete messages. |
MsgUnitRaw[] |
get(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Synchronous access a message. |
java.lang.String |
getLoginName()
|
java.lang.String |
getProtocol()
Returns the protocol type. |
java.lang.String |
getType()
Enforced by I_Plugin |
java.lang.String |
getVersion()
Enforced by I_Plugin |
void |
init(Global glob,
PluginInfo pluginInfo)
This method is called by the PluginManager (enforced by I_Plugin). |
boolean |
isLoggedIn()
|
java.lang.String |
ping(java.lang.String qos)
Check server. |
java.lang.String |
publish(MsgUnitRaw msgUnit)
Publish a message. |
java.lang.String[] |
publishArr(MsgUnitRaw[] msgUnitArr)
Publish multiple messages in one sweep. |
void |
publishOneway(MsgUnitRaw[] msgUnitArr)
Publish multiple messages in one sweep. |
void |
resetConnection()
Reset the driver on problems |
void |
setConnectReturnQos(ConnectReturnQos connectReturnQos)
Pass the driver the decrypted and parsed ConnectReturnQos directly after a connect. |
void |
shutdown()
Shut down the callback server. |
java.lang.String |
subscribe(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Enforced by I_XmlBlasterConnection interface (failsafe mode). |
java.lang.String[] |
unSubscribe(java.lang.String xmlKey_literal,
java.lang.String qos_literal)
Unsubscribe from messages. |
java.lang.String |
usage()
Command line usage. |
Methods inherited from class org.xmlBlaster.util.protocol.email.EmailExecutor |
---|
createMessageId, getBcc, getCc, getDefaultResponseTimeout, getDefaultUpdateResponseTimeout, getEmailSessionId, getEmailSessionId, getFrom, getLoopProtectionList, getLoopProtections, getMsgInfoParserClassName, getPop3Driver, getSecretSessionId, getSmtpClient, getTo, getUsageUrl, incomingMessage, init, isAlive, isLoopingMail, isShutdown, removeFromLoopProtection, sendEmail, sendEmail, sendEmail, sendEmail, sendMessage, sendUpdateOneway, setBcc, setCc, setEmailSessionId, setEmailSessionId, setFrom, setSecretSessionId, setTo, setUsageUrl |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.xmlBlaster.client.protocol.I_XmlBlasterConnection |
---|
registerProgressListener |
Methods inherited from interface org.xmlBlaster.util.protocol.RequestReplyExecutorMBean |
---|
getMinSizeForCompression, getPingResponseTimeout, getResponseTimeout, getResponseTimeout, getUpdateResponseTimeout, interruptInvocation, isCompressZlib, isCompressZlibStream, isUseEmailExpiryTimestamp, setCompressZlib, setCompressZlibStream, setMinSizeForCompression, setPingResponseTimeout, setResponseTimeout, setUpdateResponseTimeout, setUseEmailExpiryTimestamp |
Field Detail |
---|
private static java.util.logging.Logger log
private java.lang.String ME
private Global glob
protected java.lang.String loginName
private PluginInfo pluginInfo
private boolean isLoggedIn
private boolean isInitialized
private boolean stripSecurityQosCDATA
Constructor Detail |
---|
public EmailConnection()
Method Detail |
---|
public java.lang.String getLoginName()
public java.lang.String getType()
getType
in interface I_AdminPlugin
getType
in interface I_Plugin
getType
in class RequestReplyExecutor
public java.lang.String getVersion()
getVersion
in interface I_AdminPlugin
getVersion
in interface I_Plugin
public void init(Global glob, PluginInfo pluginInfo) throws XmlBlasterException
init
in interface I_Plugin
XmlBlasterException
I_Plugin.init(org.xmlBlaster.util.Global,org.xmlBlaster.util.plugin.PluginInfo)
public void connectLowlevel(Address address) throws XmlBlasterException
connectLowlevel
in interface I_XmlBlasterConnection
address
- Contains the remote address,
e.g. the host and port where the remote server listens
XmlBlasterException
- ErrorCode.COMMUNICATION* if the server is not reachable,
in this case we can poll for the server.I_XmlBlasterConnection.connectLowlevel(Address)
public void resetConnection()
resetConnection
in interface I_XmlBlasterConnection
public void setConnectReturnQos(ConnectReturnQos connectReturnQos)
I_XmlBlasterConnection
setConnectReturnQos
in interface I_XmlBlasterConnection
I_XmlBlasterConnection.setConnectReturnQos(ConnectReturnQos)
public java.lang.String connect(java.lang.String connectQos) throws XmlBlasterException
connect
in interface I_XmlBlasterConnection
connectQos
- The encrypted connect QoS
XmlBlasterException
- if login failspublic final java.lang.String getProtocol()
getProtocol
in interface I_XmlBlasterConnection
public boolean disconnect(java.lang.String qos) throws XmlBlasterException
disconnect
in interface I_XmlBlasterConnection
sessionId
- The client sessionId
XmlBlasterException
public void shutdown()
shutdown
in interface I_XmlBlasterConnection
shutdown
in interface I_AdminPlugin
shutdown
in interface I_Plugin
shutdown
in class EmailExecutor
public final boolean isLoggedIn()
isLoggedIn
in interface I_XmlBlasterConnection
public final java.lang.String subscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
subscribe
in interface I_XmlBlasterConnection
XmlBlasterException
public final java.lang.String[] unSubscribe(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
unSubscribe
in interface I_XmlBlasterConnection
XmlBlasterException
public final java.lang.String publish(MsgUnitRaw msgUnit) throws XmlBlasterException
publish
in interface I_XmlBlasterConnection
XmlBlasterException
public final java.lang.String[] publishArr(MsgUnitRaw[] msgUnitArr) throws XmlBlasterException
publishArr
in interface I_XmlBlasterConnection
XmlBlasterException
public final void publishOneway(MsgUnitRaw[] msgUnitArr) throws XmlBlasterException
publishOneway
in interface I_XmlBlasterConnection
XmlBlasterException
public final java.lang.String[] erase(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
erase
in interface I_XmlBlasterConnection
XmlBlasterException
public final MsgUnitRaw[] get(java.lang.String xmlKey_literal, java.lang.String qos_literal) throws XmlBlasterException
get
in interface I_XmlBlasterConnection
XmlBlasterException
public java.lang.String ping(java.lang.String qos) throws XmlBlasterException
ping
in interface I_XmlBlasterConnection
ping
in class EmailExecutor
qos
- Currently an empty string ""
XmlBlasterException
- If client not reachablepublic java.lang.String usage()
usage
in interface I_AdminUsage
usage
in class EmailExecutor
SmtpClient#setSessionProperties(Properties, Global, I_PluginConfig)
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |