public class dsession extends java.lang.Object implements CorbaAtmi
ApplicationToMonitorInterface
Modifier and Type | Class and Description |
---|---|
private class |
dsession.MyListener |
Modifier and Type | Field and Description |
---|---|
private int |
acl_policy |
private static java.lang.String |
ANONYMOUS_USER |
private java.util.Timer |
asyncTimeService |
private int |
auth_type |
private boolean |
cachedUR |
private java.util.concurrent.ConcurrentHashMap<CallDescriptor,TDMImport> |
cdToImpSvc |
private int |
char_codeset |
private int |
cmplimit |
private boolean |
connector |
private int |
convid |
private int |
cred_policy |
protected java.lang.String |
desired_name |
static int |
DMACL_GLOBAL |
static int |
DMACL_LOCAL |
private java.io.DataInputStream |
dom_istream |
private java.io.DataOutputStream |
dom_ostream |
protected int |
dom_protocol |
private java.net.Socket |
dom_socket |
protected java.lang.String |
dom_target_name |
private java.net.InetAddress[] |
domaddr_ip |
private int[] |
domaddr_port |
private int |
eflags |
private TuxedoMuxableSocket |
ein |
private int |
elevel |
private static boolean |
enable64BitsLong |
private TpeOut |
eout |
private int |
flags |
protected atn |
gssatn |
private java.lang.String |
identityKeyAlias |
private java.lang.String |
identityKeyPassphrase |
private java.lang.String |
identityKeyStore |
private java.lang.String |
identityKeyStorePassphrase |
private java.lang.String |
identityKeyStoreType |
protected boolean |
interoperate |
private InvokeSvc |
invoker |
private boolean |
is_connected |
private boolean |
is_term |
private JSSESocket |
jsseSock |
private int |
ka |
static int |
KA_ACTIVE |
static int |
KA_DISABLED |
static int |
KA_INIT |
static int |
KA_NONE |
static int |
KA_PENDING |
static int |
KA_SCHEDULED |
static int |
KA_SHUTDOWN |
static int |
KA_WAIT |
private long |
kaExpTime |
private int |
kas |
private int |
kaState |
private KeepAliveTask |
kaTask |
private int |
kaw |
private long |
kawExpTime |
private int |
kaws |
private long |
lastRecvTime |
private java.lang.String |
local_domain_name |
private java.lang.Object |
lockObject |
protected java.lang.String |
lpwd |
private int |
maxEncryptBits |
private int |
minEncryptBits |
private int |
minorVersion |
protected boolean |
myAllowAnon |
protected TCAppKey |
myAppKey |
protected java.lang.String |
myAppKeySel |
private long |
myBlockTime |
private ClientInfo |
myCltInfo |
protected java.lang.String |
myCustomAppKeyClass |
protected java.lang.String |
myCustomAppKeyClassParam |
protected int |
myDfltAppKey |
protected java.lang.String |
myGidKw |
protected tplle |
myLLE |
private java.util.concurrent.locks.Lock |
myLock |
private TuxRply |
myRplyObj |
private OnTerm |
myTerminationHandler |
private java.util.Timer |
myTimeService |
protected java.lang.String |
myUidKw |
private WTCStatisticsRuntimeMBeanImpl |
myWTCStat |
private WTCService |
myWTCSvc |
private TuxXidRply |
myXidRplyObj |
private rdsession |
rcv_place |
protected int |
rdom_features |
private TpeIn |
rein |
private java.lang.String |
remote_domain_id |
private weblogic.iiop.ior.IOR |
remoteCodeBase |
private int |
reqid |
private java.util.HashMap |
rmiCallList |
protected java.lang.String |
rpwd |
protected int |
security_type |
static java.lang.String |
SEL_LDAP |
static java.lang.String |
SEL_TPUSRFILE |
static int |
TM_PRIORANGE |
static int |
TM_SENDBASE |
private int |
tmsndprio |
private OatmialServices |
tos |
private java.lang.String |
tpusrfile |
private java.lang.String |
trustKeyStore |
private java.lang.String |
trustKeyStorePassphrase |
private java.lang.String |
trustKeyStoreType |
private int |
uid |
private BetaFeatures |
useBetaFeatures |
private static boolean |
useCORBATimeout |
private boolean[] |
useSDP |
private boolean |
useSSL |
private int |
wchar_codeset |
TPABSOLUTE, TPACK, TPAPPAUTH, TPCONV, TPGETANY, TPNOAUTH, TPNOBLOCK, TPNOCHANGE, TPNOREPLY, TPNOTIME, TPNOTRAN, TPRECVONLY, TPRMICALL, TPSENDONLY, TPSIGRSTRT, TPSYSAUTH, TPTRAN, TPUNKAUTH
Constructor and Description |
---|
dsession(java.util.Timer tsd,
java.net.InetAddress[] ip,
int[] port,
atn gssimpl,
InvokeSvc invoke,
int myUid,
TuxXidRply anXidRply,
BetaFeatures betaFeatures) |
dsession(java.util.Timer tsd,
java.net.InetAddress ip,
int port,
atn gssimpl,
int myUid,
TuxXidRply anXidRply,
BetaFeatures betaFeatures) |
dsession(java.util.Timer tsd,
java.net.InetAddress ip,
int port,
atn gssimpl,
InvokeSvc invoke,
int myUid,
TuxXidRply anXidRply,
BetaFeatures betaFeatures) |
dsession(java.util.Timer tsd,
java.net.InetAddress ip,
int port,
int myUid,
TuxXidRply anXidRply,
BetaFeatures betaFeatures) |
dsession(java.util.Timer tsd,
java.net.Socket tdom_socket,
atn gssimpl,
InvokeSvc invoke,
int myUid,
TuxXidRply anXidRply,
boolean useSSL,
BetaFeatures betaFeatures) |
Modifier and Type | Method and Description |
---|---|
void |
_dom_drop() |
private CallDescriptor |
_tpacall_internal(ReplyQueue rplyObj,
java.lang.String svc,
tfmh tmmsg,
int flags,
javax.transaction.xa.Xid tid,
int trantime,
MethodParameters methodParms,
boolean conversational,
TuxedoCorbaConnection aCorbaConn,
GatewayTpacallAsyncReply callBack,
TuxedoConnection tuxUser) |
private tfmh |
_tpcall_internal(java.lang.String svc,
tfmh tmmsg,
int flags,
javax.transaction.xa.Xid tid,
int trantime,
TuxedoConnection tuxUser) |
private tfmh |
_tpgetrply_internal(SessionAcallDescriptor cd,
int flags) |
void |
_tpsend_internal(tfmh tmmsg,
int sequenceNumber,
int conversationIdentifier,
boolean isInitiator,
boolean switchDirection,
boolean doDisconnect) |
TdomTcb |
alloc_TDOM(int opcode,
int flags,
java.lang.String svc) |
private int |
allocReqid() |
private void |
collect_stat_begin(TDMImport imp) |
void |
collect_stat_end(CallDescriptor cd,
long len,
boolean result,
boolean end) |
private void |
collect_stat_end(TDMImport imp,
long len,
boolean result,
boolean end) |
void |
dmqDecision() |
private void |
do_connect(java.lang.String domainid) |
void |
doLocalTerminate() |
boolean |
equals(java.lang.Object obj) |
long |
get_BlockTime() |
java.io.DataInputStream |
get_input_stream() |
InvokeSvc |
get_invoker() |
boolean |
get_is_connected() |
boolean |
get_is_connector() |
java.lang.String |
get_local_domain_name() |
java.io.DataOutputStream |
get_output_stream() |
rdsession |
get_rcv_place() |
int |
get_sess_sec() |
java.util.Timer |
get_TimeService() |
int |
getAclPolicy() |
java.lang.String |
getApplicationPassword() |
int |
getCharCodeSet() |
int |
getCompressionThreshold() |
int |
getCredentialPolicy() |
UserRec |
getCurrentUser(TuxedoConnection tuxUser) |
java.lang.String |
getDesiredName() |
int |
getELevel() |
boolean |
getFlag(int f) |
java.net.InetAddress |
getIAddress() |
java.lang.String |
getIdentityKeyStore() |
boolean |
getInteroperate() |
boolean |
getIsTerminated() |
int |
getKeepAlive() |
int |
getKeepAliveWait() |
java.lang.String |
getLocalPassword() |
int |
getMinorVersion() |
weblogic.iiop.ior.IOR |
getRemoteCodeBase() |
java.lang.String |
getRemoteDomainId() |
java.lang.String |
getRemotePassword() |
java.util.HashMap |
getRMICallList() |
protected TuxRply |
getRplyObj() |
int |
getSessionFeatures() |
java.lang.String |
getTargetName() |
java.lang.String |
getTpUserFile() |
int |
getUid() |
TuxXidRply |
getUnknownRplyObj() |
boolean |
getUseSSL() |
int |
getWcharCodeSet() |
int |
hashCode() |
boolean |
isKATimersExpired(long tick) |
boolean |
isKeepAliveAvailable() |
void |
restoreTfmhToCache(tfmh msg) |
void |
send_failure_return(java.io.Serializable rd,
TPException te,
int conversationIdentifier) |
void |
send_success_return(java.io.Serializable rd,
tfmh tmmsg,
int the_TPException,
int the_tpurcode,
int conversationIdentifier) |
void |
send_transaction_reply(tfmh tmmsg) |
void |
sendKeepAliveAcknowledge() |
void |
sendKeepAliveRequest() |
void |
set_authtype(int authtype) |
void |
set_BlockTime(long blocktime) |
void |
set_compression_threshold(int cmpl) |
void |
set_dom_target_name(java.lang.String domname) |
void |
set_invoker(InvokeSvc invoke) |
void |
set_is_connected(boolean isc) |
void |
set_local_domain_name(java.lang.String ldn) |
void |
set_rcv_place(rdsession rp) |
void |
set_sess_sec(java.lang.String sectype) |
void |
setAclPolicy(java.lang.String acl) |
void |
setAllowAnonymous(boolean val) |
void |
setAppKey(java.lang.String appkeyType) |
void |
setApplicationPassword(java.lang.String passwd) |
void |
setCodeSets(int cs,
int ws) |
void |
setCredentialPolicy(java.lang.String cred) |
void |
setCustomAppKeyClass(java.lang.String val) |
void |
setCustomAppKeyClassParam(java.lang.String val) |
void |
setDesiredName(java.lang.String desired) |
void |
setDfltAppKey(int val) |
void |
setELevel(int l) |
void |
setEncryptionFlags(int ef) |
void |
setFlag(int f) |
void |
setGidKw(java.lang.String kw) |
void |
setIdentityKeyAlias(java.lang.String alias) |
void |
setIdentityKeyPassphrase(java.lang.String ap) |
void |
setIdentityKeyStore(java.lang.String iks) |
void |
setIdentityKeyStorePassphrase(java.lang.String iksp) |
void |
setIdentityKeyStoreType(java.lang.String ikst) |
void |
setInProtocol(int protocol) |
void |
setInteroperate(boolean allowed) |
void |
setIsTerminated() |
void |
setKeepAlive(int keepalive) |
void |
setKeepAliveWait(int keepalivewait) |
void |
setLLE() |
void |
setLocalPassword(java.lang.String passwd) |
void |
setMaxEncryptBits(int bits) |
void |
setMinEncryptBits(int bits) |
void |
setMinorVersion(int minorVersion) |
private void |
setOutboundImportedXid(tfmh tmmsg,
javax.transaction.xa.Xid tid,
int mode)
If WTC/WLS is a subordinate, it is necessary to put foreignXid into
MetaTCM of the tuxedo message
|
void |
setOutProtocol(int protocol) |
void |
setRemoteCodeBase(weblogic.iiop.ior.IOR ior) |
void |
setRemoteDomainId(java.lang.String rdn) |
void |
setRemotePassword(java.lang.String passwd) |
void |
setSessionFeatures(int f) |
void |
setTerminationHandler(OnTerm terminationHandler) |
void |
setTpUserFile(java.lang.String ufile) |
void |
setTrustKeyStore(java.lang.String tks) |
void |
setTrustKeyStorePassphrase(java.lang.String tksp) |
void |
setTrustKeyStoreType(java.lang.String tkst) |
void |
setUidKw(java.lang.String kw) |
int |
setUpTuxedoAAA() |
private void |
setUse64BitsLong(tfmh tmmsg) |
void |
setUseSDP(boolean[] useSDP) |
void |
setUseSSL(boolean useSSL) |
void |
startKACountDown() |
void |
terminateTDomainSession(boolean localTermination) |
void |
tpabort(int flags) |
CallDescriptor |
tpacall(java.lang.String svc,
TypedBuffer data,
int flags)
Sends a deferred asyncronous request message to a Tuxedo service.
|
CallDescriptor |
tpacall(java.lang.String svc,
TypedBuffer data,
int flags,
TpacallAsyncReply callBack)
Sends an asyncronous request message to a Tuxedo service.
|
CallDescriptor |
tpacall(java.lang.String svc,
TypedBuffer data,
int flags,
javax.transaction.xa.Xid tid,
int trantime,
GatewayTpacallAsyncReply callBack,
TuxedoConnection tuxUser) |
void |
tpbegin(long timeout,
int flags) |
Reply |
tpcall(java.lang.String svc,
TypedBuffer data,
int flags)
Sends a request and synchronously awaits for the reply.
|
Reply |
tpcall(java.lang.String svc,
TypedBuffer data,
int flags,
javax.transaction.xa.Xid tid,
int trantime,
TuxedoConnection user) |
void |
tpcancel(CallDescriptor cd,
int flags)
Routine for cancelling a call descriptor for outstanding reply
tpcancel() cancels a call descriptor, cd, returned by tpacall().
|
int |
tpchkauth() |
void |
tpcommit(int flags) |
Txid |
tpcommit(TuxXidRply rplyObj,
javax.transaction.xa.Xid tid,
int trantime,
boolean doCommit) |
Conversation |
tpconnect(java.lang.String svc,
TypedBuffer data,
int flags)
Establishes a half-duplex connection to a conversational
service,
svc . |
Conversation |
tpconnect(java.lang.String svc,
TypedBuffer data,
int flags,
javax.transaction.xa.Xid xid,
int timeout,
TuxedoConnection tuxUser) |
DequeueReply |
tpdequeue(java.lang.String qspace,
java.lang.String qname,
byte[] msgid,
byte[] corrid,
boolean doWait,
boolean doPeek,
int flags)
Removes a message for processing from the queue named by qname
in the qspace queue space.
|
DequeueReply |
tpdequeue(java.lang.String qspace,
java.lang.String qname,
byte[] msgid,
byte[] corrid,
boolean doWait,
boolean doPeek,
int flags,
javax.transaction.xa.Xid tid,
int trantime,
TuxedoConnection tuxUser) |
DequeueReply |
tpdequeue(java.lang.String qspace,
java.lang.String qname,
int flags)
Removes a message for processing from the queue named by qname
in the qspace queue space using the following parameters:
msgid and corrid set to null. |
byte[] |
tpenqueue(java.lang.String qspace,
java.lang.String qname,
EnqueueRequest ctl,
TypedBuffer data,
int flags)
Stores a message on the queue named by qname in the qspace
queue space.
|
byte[] |
tpenqueue(java.lang.String qspace,
java.lang.String qname,
EnqueueRequest ctl,
TypedBuffer data,
int flags,
javax.transaction.xa.Xid tid,
int trantime,
TuxedoConnection tuxUser) |
Reply |
tpgetrply(CallDescriptor cd,
int flags)
Returns a reply using the call descriptor returned
by a deferred
tpacall . |
void |
tpinit(TPINIT tpinfo) |
CallDescriptor |
tpMethodReq(TypedBuffer data,
Objinfo objinfo,
MethodParameters methodParms,
TuxedoCorbaConnection aCorbaConn,
int flags,
TuxRply trp,
javax.transaction.xa.Xid tid,
int trantime,
TuxedoConnection tuxUser) |
Txid |
tpprepare(TuxXidRply rplyObj,
javax.transaction.xa.Xid tid,
int trantime) |
CallDescriptor |
tprplycall(TuxRply rplyObj,
java.lang.String svc,
TypedBuffer data,
int flags,
javax.transaction.xa.Xid tid,
int trantime,
GatewayTpacallAsyncReply callBack,
TuxedoConnection tuxUser) |
void |
tpsprio(int prio,
int flags)
Sets the priority for the next request sent or forwarded by the current
thread in the current context.
|
void |
tpterm()
Dissasociates an object from a Tuxedo
session.
|
void |
updateLastReceiveTime() |
protected java.lang.String lpwd
protected java.lang.String rpwd
protected java.lang.String desired_name
protected java.lang.String dom_target_name
protected atn gssatn
protected int dom_protocol
protected int security_type
protected tplle myLLE
protected boolean interoperate
protected TCAppKey myAppKey
protected java.lang.String myAppKeySel
protected boolean myAllowAnon
protected int myDfltAppKey
protected java.lang.String myUidKw
protected java.lang.String myGidKw
protected java.lang.String myCustomAppKeyClass
protected java.lang.String myCustomAppKeyClassParam
private int acl_policy
private int cred_policy
private java.lang.String tpusrfile
private int eflags
private int elevel
private java.net.InetAddress[] domaddr_ip
private int[] domaddr_port
private java.lang.String remote_domain_id
private java.lang.String local_domain_name
private java.net.Socket dom_socket
private java.io.DataOutputStream dom_ostream
private java.io.DataInputStream dom_istream
private TuxedoMuxableSocket ein
private JSSESocket jsseSock
private TpeOut eout
private TpeIn rein
private int auth_type
private boolean is_term
private boolean is_connected
private int reqid
private int convid
private int cmplimit
private rdsession rcv_place
private InvokeSvc invoker
private boolean connector
private int uid
private java.util.Timer myTimeService
private java.util.Timer asyncTimeService
private TuxRply myRplyObj
private long myBlockTime
private TuxXidRply myXidRplyObj
private OnTerm myTerminationHandler
private ClientInfo myCltInfo
private BetaFeatures useBetaFeatures
private java.util.HashMap rmiCallList
private java.lang.Object lockObject
private boolean cachedUR
private int tmsndprio
private int kas
private int kaws
private int ka
private int kaw
protected int rdom_features
private long lastRecvTime
private int kaState
private java.util.concurrent.locks.Lock myLock
private KeepAliveTask kaTask
private long kaExpTime
private long kawExpTime
private boolean useSSL
private java.lang.String identityKeyStoreType
private java.lang.String identityKeyStore
private java.lang.String identityKeyStorePassphrase
private java.lang.String identityKeyAlias
private java.lang.String identityKeyPassphrase
private java.lang.String trustKeyStoreType
private java.lang.String trustKeyStore
private java.lang.String trustKeyStorePassphrase
private int minEncryptBits
private int maxEncryptBits
private boolean[] useSDP
private WTCService myWTCSvc
private WTCStatisticsRuntimeMBeanImpl myWTCStat
private java.util.concurrent.ConcurrentHashMap<CallDescriptor,TDMImport> cdToImpSvc
public static final int KA_NONE
public static final int KA_INIT
public static final int KA_ACTIVE
public static final int KA_WAIT
public static final int KA_SCHEDULED
public static final int KA_SHUTDOWN
public static final int KA_DISABLED
public static final int KA_PENDING
public static final int DMACL_LOCAL
public static final int DMACL_GLOBAL
public static final int TM_PRIORANGE
public static final int TM_SENDBASE
private static final java.lang.String ANONYMOUS_USER
public static final java.lang.String SEL_TPUSRFILE
public static final java.lang.String SEL_LDAP
private static boolean useCORBATimeout
private OatmialServices tos
private static boolean enable64BitsLong
private int flags
private int char_codeset
private int wchar_codeset
private weblogic.iiop.ior.IOR remoteCodeBase
private int minorVersion
public dsession(java.util.Timer tsd, java.net.InetAddress ip, int port, int myUid, TuxXidRply anXidRply, BetaFeatures betaFeatures)
tsd
- The time service to be used with this remote domainip
- The internet address of the gateway to connect toport
- The TCP/IP port of the gateway to connect tomyUid
- A unique identifier for this dsessionanXidRply
- The XID reply object used to handle requests from the
remote domain concerning unknown XIDsbetaFeatures
- true if we are allowed to use beta featurespublic dsession(java.util.Timer tsd, java.net.InetAddress ip, int port, atn gssimpl, int myUid, TuxXidRply anXidRply, BetaFeatures betaFeatures)
tsd
- The time service to be used with this remote domainip
- The internet address of the gateway to connect toport
- The TCP/IP port of the gateway to connect togssimpl
- The atn object that implements the authorization
object necessary to run the GSS-API security protocolmyUid
- A unique identifier for this dsessionanXidRply
- The XID reply object used to handle requests from the
remote domain concerning unknown XIDsbetaFeatures
- true if we are allowed to use beta featuresatn
public dsession(java.util.Timer tsd, java.net.InetAddress[] ip, int[] port, atn gssimpl, InvokeSvc invoke, int myUid, TuxXidRply anXidRply, BetaFeatures betaFeatures)
tsd
- The time service to be used with this remote domainip
- The array of internet address of the gateway to connect toport
- The array of TCP/IP port of the gateway to connect togssimpl
- The atn object that implements the authorization
object necessary to run the GSS-API security protocolinvoke
- The invoker used to invoke servicesmyUid
- A unique identifier for this dsessionanXidRply
- The XID reply object used to handle requests from the
remote domain concerning unknown XIDsbetaFeatures
- true if we are allowed to use beta featuresatn
public dsession(java.util.Timer tsd, java.net.InetAddress ip, int port, atn gssimpl, InvokeSvc invoke, int myUid, TuxXidRply anXidRply, BetaFeatures betaFeatures)
tsd
- The time service to be used with this remote domainip
- The internet address of the gateway to connect toport
- The TCP/IP port of the gateway to connect togssimpl
- The atn object that implements the authorization
object necessary to run the GSS-API security protocolinvoke
- The invoker used to invoke servicesmyUid
- A unique identifier for this dsessionanXidRply
- The XID reply object used to handle requests from the
remote domain concerning unknown XIDsbetaFeatures
- true if we are allowed to use beta featuresatn
public dsession(java.util.Timer tsd, java.net.Socket tdom_socket, atn gssimpl, InvokeSvc invoke, int myUid, TuxXidRply anXidRply, boolean useSSL, BetaFeatures betaFeatures) throws java.io.IOException
tsd
- The time service to be used with this remote domaindom_socket
- A socket IO streamgssimpl
- The atn object that implements the authorization
object necessary to run the GSS-API security protocolmyUid
- A unique identifier for this dsessioninvoke
- The invoker used to invoke servicesanXidRply
- The XID reply object used to handle requests from the
remote domain concerning unknown XIDsbetaFeatures
- true if we are allowed to use beta featuresjava.io.IOException
public java.net.InetAddress getIAddress()
public TuxXidRply getUnknownRplyObj()
public void set_BlockTime(long blocktime)
blocktime
- The default block time for this session in millisecondspublic long get_BlockTime()
public java.util.Timer get_TimeService()
public void set_invoker(InvokeSvc invoke) throws TPException
invoke
- The object to be used when invoking servicesTPException
- if this object is already initedpublic InvokeSvc get_invoker()
public void set_dom_target_name(java.lang.String domname)
domname
- This is the string representation of the name of the
remote domain we are attempting to contactatn
,
ApplicationToMonitorInterface#tpinit
public java.lang.String getTargetName()
public void set_compression_threshold(int cmpl) throws TPException
cmpl
- the compression thresholdTPException
- if called after tpinit has been calleddsession.tpinit(weblogic.wtc.jatmi.TPINIT)
public int getCompressionThreshold()
getCompressionThreshold
in interface gwatmi
integer
specifying the compression thresholdpublic void set_sess_sec(java.lang.String sectype) throws TPException
type
- The security type.TPException
- if input security is invalidpublic int get_sess_sec()
integer
specifying the security type.public void setKeepAlive(int keepalive)
keepAlive
- the value in ms for keepAlive feature.public int getKeepAlive()
public void setKeepAliveWait(int keepalivewait)
keepAlive
- the value in ms for keepAlive feature.public int getKeepAliveWait()
public void setLocalPassword(java.lang.String passwd)
type
- The security type.public void setSessionFeatures(int f)
public int getSessionFeatures()
getSessionFeatures
in interface gwatmi
public void dmqDecision()
public void setRemotePassword(java.lang.String passwd)
type
- The security type.public void setApplicationPassword(java.lang.String passwd)
type
- The security type.public java.lang.String getLocalPassword()
public java.lang.String getRemotePassword()
public java.lang.String getApplicationPassword()
public void setDesiredName(java.lang.String desired)
desired_name
- public java.lang.String getDesiredName()
public void setEncryptionFlags(int ef)
eflags
- the encryption flagspublic void setELevel(int l)
l
- the level.public int getELevel()
public void setLLE()
public void setAclPolicy(java.lang.String acl)
acl
- The String value of ACL_POLICY, either LOCAL or GLOBALpublic void setCredentialPolicy(java.lang.String cred)
acl
- The String value of CREDENTIAL_POLICY, either LOCAL or GLOBALpublic int getAclPolicy()
public int getCredentialPolicy()
public void setTpUserFile(java.lang.String ufile)
acl
- The String value of the full path name to TPUSERFILEpublic java.lang.String getTpUserFile()
public int setUpTuxedoAAA()
public void setInteroperate(boolean allowed)
allowed
- is a boolean, if true then allow else not allowed.public boolean getInteroperate()
public boolean getIsTerminated()
getIsTerminated
in interface gwatmi
public void setIsTerminated()
setIsTerminated
in interface gwatmi
public void doLocalTerminate()
doLocalTerminate
in interface gwatmi
public boolean get_is_connected()
public void set_is_connected(boolean isc)
isc
- true if we are connected, false otherwisepublic java.lang.String get_local_domain_name()
public void set_local_domain_name(java.lang.String ldn)
ldm
- The local domain namepublic java.lang.String getRemoteDomainId()
public void setRemoteDomainId(java.lang.String rdn)
rdm
- The remote domain idpublic void setAppKey(java.lang.String appkeyType)
type
- The AppKey plug-in type.public void setDfltAppKey(int val)
val
- The default AppKey value.public void setAllowAnonymous(boolean val)
allow
- the status of allow anonymous user.public void setUidKw(java.lang.String kw)
kw
- The custom UID keyword used in LDAP.public void setGidKw(java.lang.String kw)
kw
- The custom GID keyword used in LDAP.public void setCustomAppKeyClass(java.lang.String val)
cls
- The custom AppKey plug-in full pathname.public void setCustomAppKeyClassParam(java.lang.String val)
param
- The initialization parameters.public int tpchkauth() throws TPException
TPException
- if called in an illegal statepublic void set_authtype(int authtype)
authtype
- The type of authorization needed for this domainpublic boolean get_is_connector()
public java.io.DataOutputStream get_output_stream()
public java.io.DataInputStream get_input_stream()
public void setInProtocol(int protocol)
protocol
- The protocol that will be spoken to the remote domainpublic void setOutProtocol(int protocol)
public void set_rcv_place(rdsession rp)
The
- object used to receive messagespublic rdsession get_rcv_place()
The
- object used to receive messagespublic void setUseSSL(boolean useSSL)
public boolean getUseSSL()
public void setIdentityKeyStoreType(java.lang.String ikst)
public void setIdentityKeyStore(java.lang.String iks)
public java.lang.String getIdentityKeyStore()
public void setIdentityKeyStorePassphrase(java.lang.String iksp)
public void setIdentityKeyAlias(java.lang.String alias)
public void setIdentityKeyPassphrase(java.lang.String ap)
public void setTrustKeyStoreType(java.lang.String tkst)
public void setTrustKeyStore(java.lang.String tks)
public void setTrustKeyStorePassphrase(java.lang.String tksp)
public void setMinEncryptBits(int bits)
public void setMaxEncryptBits(int bits)
public final int getMinorVersion()
public final void setMinorVersion(int minorVersion)
public final void setCodeSets(int cs, int ws)
public final int getWcharCodeSet()
public final int getCharCodeSet()
public void setFlag(int f)
public boolean getFlag(int f)
public final weblogic.iiop.ior.IOR getRemoteCodeBase()
public final void setRemoteCodeBase(weblogic.iiop.ior.IOR ior)
public void setUseSDP(boolean[] useSDP)
private void setUse64BitsLong(tfmh tmmsg)
private void do_connect(java.lang.String domainid) throws TPException
TPException
public void _dom_drop()
public void terminateTDomainSession(boolean localTermination)
public void tpinit(TPINIT tpinfo) throws TPException
tpinfo
- The representation of the remote domainTPException
- if we cannot connect to the remote domainpublic void tpterm() throws TPException
ApplicationToMonitorInterface
tpterm
has been called.tpterm
in interface ApplicationToMonitorInterface
TPException
- if called in the wrong contextprivate int allocReqid()
public TdomTcb alloc_TDOM(int opcode, int flags, java.lang.String svc) throws TPException
TPException
private CallDescriptor _tpacall_internal(ReplyQueue rplyObj, java.lang.String svc, tfmh tmmsg, int flags, javax.transaction.xa.Xid tid, int trantime, MethodParameters methodParms, boolean conversational, TuxedoCorbaConnection aCorbaConn, GatewayTpacallAsyncReply callBack, TuxedoConnection tuxUser) throws TPException
rplyObj
- If not null the reply object upon which this request should
be placed. If null, then the reply to this request should be placed on the
normal reply queuesvc
- The service this message is headed fortmmsg
- A message buffer that already has all of its TCMs (including
the user TCM) except for its TDOM TCM. The TDOM TCM will be
attached by this routineflags
- Same as the flags for tpacall. Not checked in this functiontid
- The transaction id to be used with this requesttrantime
- The transaction timeout (in seconds) to be used with
this call (only used if tid is non-null)conversational
- true if this is conversational, false otherwiseaCorbaConn
- A corba connection.callBack
- The callBack to use with this request, or null if no call backtuxUser
- The identity of the user who is making the request.TPException
- in case of error sending requesttpgetrply
public CallDescriptor tpacall(java.lang.String svc, TypedBuffer data, int flags, javax.transaction.xa.Xid tid, int trantime, GatewayTpacallAsyncReply callBack, TuxedoConnection tuxUser) throws TPException
tpacall
in interface gwatmi
svc
- The service name to calldata
- The data to send to the serviceflags
- tid
- The transaction id to be used with this requesttrantime
- The transaction timeout to be used with this requestcallBack
- The callback object to be used with this request, or null if none is
to be used at allTPException
- Upon failure, tpacall() returns a TPException exception
to indicate the error condition. tperrno in TPException will be set to one
of the following values:tpacall sends a request message to the service named by svc. The request is sent out at the priority defined for svc unless overridden by a previous call to tpsprio(). If data is non-null, it must point to an object that implements the TypedBuffer interface. If data is null a request is sent with no data portion. The type and sub-type of data must match one of the types and sub-types recognized by svc. Note that for each request sent while in transaction mode, a corresponding reply must ultimately be received.
public CallDescriptor tpacall(java.lang.String svc, TypedBuffer data, int flags) throws TPException
ApplicationToMonitorInterface
tpacall
service call sends a
request to a Tuxedo service and immediately returns from the call. The service
specified (svc
) must be advertised by your Tuxedo application. Upon successful
completion of the call, tpacall
returns an object that serves
as a descriptor. The calling thread is now available to perform other tasks.
You can use the call descriptor to get the correct reply for the sent request
using tpgetreply
or cancel an outstanding message reply using
tpcancel
.
A tpacall
message request is sent with a message priority of 50.
The type and sub-type of data
must match one of the types and
sub-types recognized by svc
. If data
is non-null,
it must point to an object that implements the TypedBuffer interface.
If data
is null, a request is sent with no data portion.
If tpacall
is in a transaction, you must receive the reply
using tpgetreply
before the transaction can commit. You can
not use tpcancel
to cancel a call descriptor associated
with a transaction.
tpacall
in interface ApplicationToMonitorInterface
svc
- The name of the Tuxedo servicedata
- Pointer to the data buffer; null specifies no data sentflags
- svc
is invoked, the call does not becoome part of the
caller's transaction. If svc
belongs to a server that does not
support transactions, this flag must be set when the caller is
in transaction mode. Note that svc
may still be invoked in
transaction mode but it will not be the same transaction: a svc
may
have a configuration attribute that it is automatically invoked
in transaction mode. A caller in transaction mode that sets this flag
is still subject to the transaction timeout (and no other). If a
service fails that was invoked with this flag, the caller's
transaction is not affected.
tpgetreply
or
tpcancel
.TPException
- Returns a TPException indicating the error condition.
tperrno
is set to one of the following values:svc
is null
or flags are invalid.
svc
does not exist or is a
conversational service.
data
does not match the
type and sub-type expected by svc
.
svc
belongs to a server that does not support transactions
and TPNOTRAN was not set.
tpacall
with TPNOTRAN,
TPNOBLOCK, and TPNOREPLY set.tpacall
was called improperly.
tpacall
returned successfully.
public CallDescriptor tpacall(java.lang.String svc, TypedBuffer data, int flags, TpacallAsyncReply callBack) throws TPException
ApplicationToMonitorInterface
tpacall
service call sends a request
to a Tuxedo service and releases the thread resource that performed
the call to the thread pool. This allows a very large number of outstanding
requests to be serviced with a much smaller number of threads. The service specified
(svc
) must be advertised by your Tuxedo application. Upon successful
completion of the call, asynchronous tpacall
returns an object that
serves as a descriptor. The calling thread is now available to perform other tasks.
You can use the call descriptor to identify the correct message reply from TpacallAsynchReply
for a sent message request or cancel an outstanding message reply using tpcancel
.
You can not use the call descriptor to invoke tpgetreply().tpacall
in interface ApplicationToMonitorInterface
svc
- The name of the Tuxedo servicedata
- Pointer to the data buffer; null specifies no data sentflags
- svc
is invoked, the call does not becoome part of the
caller's transaction. If svc
belongs to a server that does not
support transactions, this flag must be set when the caller is
in transaction mode. Note that svc
may still be invoked in
transaction mode but it will not be the same transaction: a svc
may
have a configuration attribute that it is automatically invoked
in transaction mode. A caller in transaction mode that sets this flag
is still subject to the transaction timeout (and no other). If a
service fails that was invoked with this flag, the caller's
transaction is not affected.
callBack
- The object to invoke when the service reply is ready. If the original request succeeded,
the TpacallAsynchReply.sucess
method returns the reply from the service. If the original
request failed, the TpacallAsynchReply.failure
method returns a failure code. If null,
the request becomes a deferred asyncronous tpacall
.TPException
- Returns a TPException indicating the error condition.
If an exception is thrown by this method the callBack will not
be invoked.
tperrno
is set to one of the following values:svc
is null
or flags are invalid.
svc
does not exist or is a
conversational service.
data
does not match the
type and sub-type expected by svc
.
svc
belongs to a server that does not support transactions
and TPNOTRAN was not set.
tpacall
with TPNOTRAN,
TPNOBLOCK, and TPNOREPLY set.tpacall
was called improperly.
tpacall
returned successfully.public void tpcancel(CallDescriptor cd, int flags) throws TPException
Upon success, cd is no longer valid and any reply received on behalf of cd will be silently discarded.
tpcancel
in interface ApplicationToMonitorInterface
cd
- A call descriptor previously returned by tpacall. Note
that this call descriptor can be for a deferred synchronous or
asynchronous call descriptor (in other words, it can be used for
both forms of tpacall)flags
- Must be zeroTPExcpetion
- The following return codes may be thrown:TPException
private tfmh _tpgetrply_internal(SessionAcallDescriptor cd, int flags) throws TPException
TPException
public Reply tpgetrply(CallDescriptor cd, int flags) throws TPException, TPReplyException
ApplicationToMonitorInterface
tpacall
.
tpgetreply
waits until the reply matching
the call descriptor, cd
arrives or a timeout occurs.Within any particular context of a multithreaded program:
tpgetrply(TPGETANY)
and tpgetrply
for a
specific handle cannot be issued concurrently.
tpgetrply(TPGETANY)
cannot be issued concurrently.
tpgetrply
call causes a violation of
either of these restrictions throws a TPException with errno
set to
TPEPROTO
.
tpgetrply
for different handles
tpgetrply(TPGETANY)
in a single context concurrently
with a call to tpgetrply, with or without TPGETANY
,
in a different context.
tpgetrply
in interface ApplicationToMonitorInterface
cd
- The call descriptor previously returned from tpacall.flags
- The following is a list of valid flags:TPException
- Upon failure, tpgetrply() throws TPException() to indicate the
error condition. tperrno in TPException will be set to one of the following
values:TPReplyException
- If there is a service failure (TPESVCFAIL or
TPSVCERROR) in which case the exception will also have reply
data from the service. However, unlike the tpcall
case, this
execption may also be thrown in any of the above TPException cases as well,
so that specific TPException return codes can be matched with the
request object returned from tpacall
. If TPReplyException is thrown
then it is on behalf of an outstanding request and that request is considered
to have completed with a failure.Within any particular context of a multithreaded program:
private tfmh _tpcall_internal(java.lang.String svc, tfmh tmmsg, int flags, javax.transaction.xa.Xid tid, int trantime, TuxedoConnection tuxUser) throws TPException
TPException
public Reply tpcall(java.lang.String svc, TypedBuffer data, int flags, javax.transaction.xa.Xid tid, int trantime, TuxedoConnection user) throws TPException, TPReplyException
tpcall
in interface gwatmi
svc
- The service name to calldata
- The data to send to the serviceflags
- The following is a list of valid flags:tid
- The transaction id to be used with this requesttrantime
- The transaction timeout (in seconds) to be used with
this call (only used if tid is non-null)TPException
- Upon failure, tpcall() sets tperrno in TPException to one of the
following values. (Unless otherwise noted, failure does not affect
the caller's transaction, if one exists.) TPReplyException
- If there was a service failure (TPESVCFAIL or
TPSVCERROR) in which case the exception will also have the reply
data from the service.public Reply tpcall(java.lang.String svc, TypedBuffer data, int flags) throws TPException, TPReplyException
ApplicationToMonitorInterface
tpcall
is the same as a deferred tpacall
immediately followed by tpgetrply
. tpcall
sends a
request to the service named by svc
. The
request is sent out at the priority defined for svc
unless overridden by
a previous call to tpsprio
. The type and sub-type of data must match
one of the types and sub-types recognized by svc
.tpcall
in interface ApplicationToMonitorInterface
svc
- The name of the Tuxedo servicedata
- Pointer to the data buffer; null specifies no data sentflags
- The following is a list of valid flags:tpcall
- the function may block when waiting for the reply. When
TPNOBLOCK is not specified and a blocking condition exists, the
caller blocks until the condition subsides or a timeout occurs
(either transaction or blocking timeout).
tpcall
returns a reply object that contains the
reply data from the service and the service return status.
You should always check the return status
of the reply object to determine if the service returned successfully.TPException
- Upon failure tpcall
sets tperrno in TPException to one of the
following values. Unless otherwise noted, failure does not affect
the caller's transaction, if one exists. svc
is null or
flags are invalid.
svc
because it does not exist, it is a
conversational service, or the name provided begins with "." - a dot.
svc
accepts.
svc
belongs to a server that does not support transactions
and TPNOTRAN was not set.
tpacall
with TPNOTRAN, TPNOBLOCK,
and TPNOREPLY set.
tpcall
was called improperly.
tpcall
returned successfully.
TPReplyException
- If there was a service failure (TPESVCFAIL or
TPSVCERROR), the exception will also have the reply data from the service.public void tpbegin(long timeout, int flags) throws TPException
timeout
- the transaction timeoutflags
- must be zeroTPException
- in all casesApplicationToMonitorInterface#tpbegin
,
TPException
public void tpabort(int flags) throws TPException
flags
- must be zeroTPException
- in all casesApplicationToMonitorInterface#tpabort
,
TPException
public void tpcommit(int flags) throws TPException
flags
- must be zeroTPException
- in all casesApplicationToMonitorInterface#tpcommit
,
TPException
public byte[] tpenqueue(java.lang.String qspace, java.lang.String qname, EnqueueRequest ctl, TypedBuffer data, int flags, javax.transaction.xa.Xid tid, int trantime, TuxedoConnection tuxUser) throws TPException
tpenqueue
in interface gwatmi
qspace
- Same as in atmi interfaceqname
- Same as in atmi interfacectl
- Same as in atmi interfacedata
- Same as in atmi interfaceflags
- Same as in atmi interfacetid
- Same as in gwatmi interfacetrantime
- Same as in gwatmi interfaceSame
- as in atmi interfaceTPException
- same as ApplicationToMonitorInterface interfacepublic byte[] tpenqueue(java.lang.String qspace, java.lang.String qname, EnqueueRequest ctl, TypedBuffer data, int flags) throws TPException
ApplicationToMonitorInterface
When the message is intended for a BEA Tuxedo system server, the qname matches the name of a service provided by the server. The system provided server, TMQFORWARD(5), provides a default mechanism for dequeuing messages from the queue and forwarding them to servers that provide a service matching the queue name. If the originator expects a reply, then the reply to the forwarded service request is stored on the originator's queue, unless otherwise specified. The originator will dequeue the reply message at a subsequent time. Queues can also be used for a reliable message transfer mechanism between any pair of BEA Tuxedo system processes (clients and/or servers). In this case, the queue name does not match a service name but some agreed upon name for transferring the message.
If data is non-null, it must point to an object that implements the TypedBuffer interface. If data is null a message is queued with no data portion.
The message is queued at the priority defined for qspace unless overridden by a previous call to tpsprio().
If the caller is within a transaction and the TPNOTRAN flag is not set, the message is queued in transaction mode. This has the effect that if tpenqueue() returns successfully and the caller's transaction is committed successfully, then the message is guaranteed to be available subsequent to the transaction completing. If the caller's transaction is rolled back either explicitly or as the result of a transaction timeout or some communication error, then the message will be removed from the queue (that is, the placing of the message on the queue is also rolled back). It is not possible to enqueue then dequeue the same message within the same transaction.
The message is not queued in transaction mode if either the caller is not in transaction mode, or the TPNOTRAN flag is set. Once tpenqueue() returns successfully, the submitted message is guaranteed to be in the queue. When not in transaction mode, if a communication error or a timeout occurs, the application will not know whether or not the message was successfully stored on the queue.
The order in which messages are placed on the queue is controlled by the application via ctl object as described in the EnqueueRequest manual page; the default queue ordering is set when the queue is created.
Additional information about queuing the message can be specified via ctl object. This information includes values to override the default queue ordering placing the message at the top of the queue or before an enqueued message; an absolute or relative time after which a queued message is made available; an absolute or relative time when a message expires and is removed from the queue; the quality of service for delivering the message; the quality of service that any replies to the message should use; a correlation identifier that aids in correlating a reply or failure message with the queued message; the name of a queue to which a reply should be enqueued; and the name of a queue to which any failure message should be enqueued. See the EnqueueRequest object for more information.
tpenqueue
in interface ApplicationToMonitorInterface
qspace
- Same as in atmi interfaceqname
- Same as in atmi interfacectl
- Same as in atmi interfacedata
- Same as in atmi interfaceflags
- Same as in atmi interfaceSame
- as in atmi interfaceTPException
- Upon failure, tpenqueue() sets tperrno in TPException
to one of the following values (unless otherwise noted, failure does not
affect the callers transaction, if one exists)
public DequeueReply tpdequeue(java.lang.String qspace, java.lang.String qname, byte[] msgid, byte[] corrid, boolean doWait, boolean doPeek, int flags, javax.transaction.xa.Xid tid, int trantime, TuxedoConnection tuxUser) throws TPException
tpdequeue
in interface gwatmi
qspace
- Same as in atmi interfaceqname
- Same as in atmi interfacemsgid
- Same as in atmi interfacecorrid
- Same as in atmi interfacedoWait
- Same as in atmi interfacedoPeek
- Same as in atmi interfaceflags
- Same as in atmi interfacetid
- Same as in gwatmi interfacetrantime
- Same as in gwatmi interfacetuxUser
- user identity of the requester.Same
- as in atmi interfaceTPException
- same as ApplicationToMonitorInterface interfacepublic DequeueReply tpdequeue(java.lang.String qspace, java.lang.String qname, byte[] msgid, byte[] corrid, boolean doWait, boolean doPeek, int flags) throws TPException
ApplicationToMonitorInterface
By default, the message at the top of the queue is dequeued. The order of messages on the queue is defined when the queue is created. The application can request a particular message for dequeuing by specifying its message identifier or correlation identifier. There are also parameters used to indicate that the application wants to wait for a message, in the case when a message is not currently available. It is possible to use tpdequeue to look at a message without removing it from the queue or changing its relative position on the queue.
The message is dequeued in transaction mode if the caller is in transaction mode and the TPNOTRAN flag is not set. This has the effect that if tpdequeue() returns successfully and the caller's transaction is committed successfully, then the message is removed from the queue. If the caller's transaction is rolled back either explicitly or as the result of a transaction timeout or some communication error, then the message will be left on the queue (that is, the removal of the message from the queue is also rolled back). It is not possible to enqueue and dequeue the same message within the same transaction.
The message is not dequeued in transaction mode if either the caller is not in transaction mode, or the TPNOTRAN flag is set. When not in transaction mode, if a communication error or a timeout occurs, the application will not know whether or not the message was successfully dequeued and the message may be lost.
tpdequeue
in interface ApplicationToMonitorInterface
qspace
- Same as in atmi interfaceqname
- Same as in atmi interfacemsgid
- Same as in atmi interfacecorrid
- Same as in atmi interfacedoWait
- Same as in atmi interfacedoPeek
- Same as in atmi interfaceflags
- Same as in atmi interfaceSame
- as in atmi interfaceTPException
- tperrno is set to
one of the following values. (Unless otherwise noted, failure does not
affect the caller's transaction, if one exists.)
public DequeueReply tpdequeue(java.lang.String qspace, java.lang.String qname, int flags) throws TPException
ApplicationToMonitorInterface
msgid
and corrid
set to null.
doWait
and doPeek
set to false.tpdequeue
in interface ApplicationToMonitorInterface
qspace
- Same as in atmi interfaceqname
- Same as in atmi interfaceflags
- Same as in atmi interfaceSame
- as in atmi interfaceTPException
public void send_success_return(java.io.Serializable rd, tfmh tmmsg, int the_TPException, int the_tpurcode, int conversationIdentifier) throws TPException
send_success_return
in interface gwatmi
rd
- The request ID for which this is a replytmmsg
- The message to send to the remote system, complete with
any extra TCMs that need to be added. This routine will only add
the tdom TCM, thank you very much.the_TPException
- Must be 0, TPESVCERR or TPESVCFAIL.the_tpurcode
- The tpurcode to send to the userconversationIdentifier
- The conversation id of this messageTPException
- if there was an error sending the replypublic void send_transaction_reply(tfmh tmmsg) throws TPException
send_transaction_reply
in interface gwatmi
tmmsg
- The message to send to the remote system, complete with
any extra TCMs that need to be added.TPException
- if there was an error sending the replypublic void send_failure_return(java.io.Serializable rd, TPException te, int conversationIdentifier)
send_failure_return
in interface gwatmi
rd
- The request ID for which this is a replyte
- The TPException that should be thrownconversationIdentifier
- The conversation identifier to use in failureTPException
- if there was an error sending the responsepublic CallDescriptor tprplycall(TuxRply rplyObj, java.lang.String svc, TypedBuffer data, int flags, javax.transaction.xa.Xid tid, int trantime, GatewayTpacallAsyncReply callBack, TuxedoConnection tuxUser) throws TPException
tprplycall
in interface gwatmi
rplyObj
- The Tuxedo Reply object upon which the reply to this request
will be enqueuedsvc
- Same as tpacalldata
- Same as tpacallflags
- Same as tpacalltid
- The transaction id to be used with this requesttrantime
- The transaction timeout (in secondes) to be used with
this call (only used if tid is non-null)callBack
- Same as tpacallTPException
- Same as tpacallpublic Txid tpprepare(TuxXidRply rplyObj, javax.transaction.xa.Xid tid, int trantime) throws TPException
tpprepare
in interface gwatmi
rplyObj
- The Tuxedo Reply object upon which the reply to this request
will be enqueuedtid
- The transaction id to be prepared (may not be null)trantime
- The transaction timeout (in secondes) to be used with
this callTPException
- If some communication error occurspublic Txid tpcommit(TuxXidRply rplyObj, javax.transaction.xa.Xid tid, int trantime, boolean doCommit) throws TPException
tpcommit
in interface gwatmi
trp
- The object upon which to place the replytid
- The Xid to commit (may not be null)trantime
- The transaction timeout (in secondes) to be used with
this calldoCommit
- True if this transaction should be committed, false if this
transaction should be rolled backTPException
- upon various errorspublic int getUid()
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public Conversation tpconnect(java.lang.String svc, TypedBuffer data, int flags, javax.transaction.xa.Xid xid, int timeout, TuxedoConnection tuxUser) throws TPException
tpconnect
in interface gwatmi
svc
- The conversational service to invokedata
- The initial data to send to the serviceflags
- The following is the list of valid flags xid
- The transaction id to be used with this requesttimeout
- The transaction timeout (in seconds) to be used with
this call (only used if tid is non-null)TPException
- Upon failure, tpconnect() returns a TPException exception
to indicate the error condition. tperrno in TPException will be set to one
of the following values:public Conversation tpconnect(java.lang.String svc, TypedBuffer data, int flags) throws TPException
ApplicationToMonitorInterface
svc
. The name must be one of the conversational service
names posted by a conversational server.
As part of setting up the connection, the caller can pass application data
to the listening program. If the caller chooses to pass data, then
data must be a TypedBuffer. The type and subtype of data must match one
of the types and sub-types recognized by svc
. data
is passed to the
conversational service via the TPServiceInformation structure with which
the service is invoked. The service does not have to call tprecv
to get
the data.tpconnect
in interface ApplicationToMonitorInterface
svc
- The conversational service to invokedata
- The initial data to send to the serviceflags
- The following is the list of valid flags svc
is invoked, it is not performed on behalf of the
caller's transaction. Note that code>svc may still be invoked in
transaction mode but it will not be the same transaction: a code>svc may
have as a configuration attribute that it is automatically invoked in
transaction mode. A caller in transaction mode that sets this flag is
still subject to the transaction timeout and no other time out. If a service
fails that was invoked with this flag, the caller's transaction
is not affected.
tpconnect
, the function may block waiting for the reply. When
TPNOBLOCK is not specified and a blocking condition exists, the
caller blocks until the condition subsides or a timeout occurs
(either transaction or blocking timeout).
tpconnect
returns an object that
can be used to send and receive data on this conversation.TPException
- Upon failure, ttpconnect
returns a TPException exception
to indicate the error condition. tperrno in TPException will be set to one
of the following values:svc
is null
or flags are invalid.
tpacall
with TPNOTRAN,
TPNOBLOCK, and TPNOREPLY set.
tpconnect
was called improperly.
public void setTerminationHandler(OnTerm terminationHandler)
setTerminationHandler
in interface gwatmi
The
- object that should be used to handle terminations, or NULL
if the handler is to be disabledpublic void restoreTfmhToCache(tfmh msg)
restoreTfmhToCache
in interface gwatmi
tmmsg
- The tfmh object that may be re-used for a cachepublic CallDescriptor tpMethodReq(TypedBuffer data, Objinfo objinfo, MethodParameters methodParms, TuxedoCorbaConnection aCorbaConn, int flags, TuxRply trp, javax.transaction.xa.Xid tid, int trantime, TuxedoConnection tuxUser) throws TPException
tpMethodReq
in interface CorbaAtmi
data
- Same as tpMethodReq inherited from CorbaAtmiobjinfo
- Same as tpMethodReq inherited from CorbaAtmimethodParms
- Same as tpMethodReq inherited from CorbaAtmiflags
- Same as tpMethodReq inherited from CorbaAtmitrp
- Same as tpMethodReq inherited from CorbaAtmitid
- Same as tpMethodReq inherited from CorbaAtmitrantime
- Same as tpMethodReq inherited from CorbaAtmiTPException
- Same as tpMethodReq inherited from CorbaAtmiprotected TuxRply getRplyObj()
public void _tpsend_internal(tfmh tmmsg, int sequenceNumber, int conversationIdentifier, boolean isInitiator, boolean switchDirection, boolean doDisconnect) throws TPException
tmmsg
- The message to send (without the user data, I'm afraid)sequenceNumber
- The sequence number to use with this sendconversationIdentifier
- The conversation identifier to useisInitiator
- true if this process was the initiator of the conversationswitchDirection
- true if we should switch to receive only modedoDisconnect
- true if this is a disconnect send rather than a tpsendTPException
public java.util.HashMap getRMICallList()
public UserRec getCurrentUser(TuxedoConnection tuxUser)
public void tpsprio(int prio, int flags) throws TPException
ApplicationToMonitorInterface
tpenqueue
or tpdequeue
. By default,
the setting of prio
increments or decrements a service's
default priority up to a maximum of 100 or down to a minimum of 1,
depending on its sign, where 100 is the highest priority. The default
priority for a request is determined by the service to which the request
is being sent. This default may be specified administratively
(see UBBCONFIG(5)), or take the system default of 50. tpsprio() has no
effect on messages sent via tpconnect or tpsend
.
A lower priority message does not remain enqueued forever because every
tenth message is retrieved on a "first in, first out" (FIFO) basis.
Response time should not be a concern of the lower priority interface or
service.
flags
may be set to 0 or may be set to TPABSOLUTE.
If TPABSOLUTE is set, then the priority of the next request should be
sent out at the absolute value of prio. The absolute value of prio must
be within the range 1 and 100, inclusive, with 100 being the highest
priority. Any value outside of this range causes a default value to be
used.
tpsprio
in interface ApplicationToMonitorInterface
TPException
tpenqueue
or tpdequeue
. By default,
the setting of prio
increments or decrements a service's
default priority up to a maximum of 100 or down to a minimum of 1,
depending on its sign, where 100 is the highest priority. The default
priority for a request is determined by the service to which the request
is being sent. This default may be specified administratively
(see UBBCONFIG(5)), or take the system default of 50. tpsprio() has no
effect on messages sent via tpconnect or tpsend
.
A lower priority message does not remain enqueued forever because every
tenth message is retrieved on a "first in, first out" (FIFO) basis.
Response time should not be a concern of the lower priority interface or
service.
flags
may be set to 0 or may be set to TPABSOLUTE.
If TPABSOLUTE is set, then the priority of the next request should be
sent out at the absolute value of prio. The absolute value of prio must
be within the range 1 and 100, inclusive, with 100 being the highest
priority. Any value outside of this range causes a default value to be
used.
public void sendKeepAliveRequest()
public void sendKeepAliveAcknowledge()
public void startKACountDown()
public void updateLastReceiveTime()
public boolean isKATimersExpired(long tick)
public boolean isKeepAliveAvailable()
private void collect_stat_begin(TDMImport imp)
private void collect_stat_end(TDMImport imp, long len, boolean result, boolean end)
public void collect_stat_end(CallDescriptor cd, long len, boolean result, boolean end)
collect_stat_end
in interface gwatmi
cd
- result
- end
- private void setOutboundImportedXid(tfmh tmmsg, javax.transaction.xa.Xid tid, int mode)
tmmsg:
- tuxedo messgaetid
- : transaction idmode
- : 1 indicate to check if tid is an instance of TuxedoXid