Java Doc for JMSLinkProtocol.java in » Science » Cougaar12_4 » org » cougaar » mts » jms » Java Source Code / Java DocumentationJava Source Code and Java Documentation
Java Source Code / Java Documentation
1.
6.0 JDK Core
2.
6.0 JDK Modules
3.
6.0 JDK Modules com.sun
4.
6.0 JDK Modules com.sun.java
5.
6.0 JDK Modules sun
6.
6.0 JDK Platform
7.
Ajax
8.
Apache Harmony Java SE
9.
Aspect oriented
10.
Authentication Authorization
11.
Blogger System
12.
Build
13.
Byte Code
14.
Cache
15.
Chart
16.
Chat
17.
Code Analyzer
18.
Collaboration
19.
Content Management System
20.
Database Client
21.
Database DBMS
22.
Database JDBC Connection Pool
23.
Database ORM
24.
Development
25.
EJB Server geronimo
26.
EJB Server GlassFish
27.
EJB Server JBoss 4.2.1
28.
EJB Server resin 3.1.5
29.
ERP CRM Financial
30.
ESB
31.
Forum
32.
GIS
33.
Graphic Library
34.
Groupware
35.
HTML Parser
36.
IDE
37.
IDE Eclipse
38.
IDE Netbeans
39.
Installer
40.
Internationalization Localization
41.
Inversion of Control
42.
Issue Tracking
43.
J2EE
44.
JBoss
45.
JMS
46.
JMX
47.
Library
48.
Mail Clients
49.
Net
50.
Parser
51.
PDF
52.
Portal
53.
Profiler
54.
Project Management
55.
Report
56.
RSS RDF
57.
Rule Engine
58.
Science
59.
Scripting
60.
Search Engine
61.
Security
62.
Sevlet Container
63.
Source Control
64.
Swing Library
65.
Template Engine
66.
Test Coverage
67.
Testing
68.
UML
69.
Web Crawler
70.
Web Framework
71.
Web Mail
72.
Web Server
73.
Web Services
74.
Web Services apache cxf 2.0.1
75.
Web Services AXIS2
76.
Wiki Engine
77.
Workflow Engines
78.
XML
79.
XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation
»
Science
»
Cougaar12_4
»
org.cougaar.mts.jms
Source Cross Reference
Class Diagram
Java Document (Java Doc)
org.cougaar.mts.base
.RPCLinkProtocol
org.cougaar.mts.jms
.JMSLinkProtocol
JMSLinkProtocol
public
class JMSLinkProtocol extends
RPCLinkProtocol
implements MessageListener
(Code)
This class implements a Cougaar LinkProtocol that uses JMS as the transport.
Inner Class :
protected
class JMSExceptionListener implements ExceptionListener
Inner Class :
public
class JMSLink extends Link
Method Summary
protected
void
closeConnection
()
protected
void
closeConsumer
(MessageConsumer consumer)
protected
void
closeContext
()
protected
int
computeCost
(
AttributedMessage
message)
protected
DestinationLink
createDestinationLink
(
MessageAddress
address)
protected
Session
ensureSession
()
protected
String
extractDestinationName
(
URI
ref)
protected
void
fillContextProperties
(
Map
<
String
,
Object
> properties)
protected
void
findOrMakeNodeServant
()
final
protected
ReplySync
findOrMakeReplySync
()
protected
void
flushObsoleteMessages
()
protected
Connection
getConnection
()
protected
MessageConsumer
getConsumer
()
protected
Context
getContext
()
protected
ConnectionFactory
getFactory
()
protected
MessageProducer
getGenericProducer
()
protected
String
getMyServantId
(
String
node)
protected
String
getProtocolType
()
protected
String
getSelector
(
String
myServantId)
protected
Destination
getServant
()
protected
Session
getSession
()
protected
boolean
isServantAlive
()
public
void
load
()
protected
Destination
lookupDestinationInContext
(
String
destinationName)
protected
Connection
makeConnection
()
protected
ConnectionFactory
makeConnectionFactory
()
protected
InitialContext
makeInitialContext
(
Hashtable
<
String
,
Object
> properties)
protected
MessageConsumer
makeMessageConsumer
(Session session, Destination destination,
String
ServantID)
protected
MessageReceiver
makeMessageReceiver
(
ReplySync
sync,
MessageDeliverer
deliverer)
protected
MessageSender
makeMessageSender
(
ReplySync
replySync)
protected
MessageProducer
makeProducer
(Destination destination)
protected
ReplySync
makeReplySync
()
protected
Destination
makeServantDestination
(
String
myServantId)
protected
Session
makeSession
()
protected
void
makeSessionExceptionListener
()
protected
URI
makeURI
(
String
myServantId)
public
void
onMessage
(Message msg)
protected
void
rebindDestinationInContext
(
String
name, Destination destination)
protected
void
releaseNodeServant
()
protected
void
remakeNodeServant
()
protected
void
subscribeConsumer
(MessageConsumer consumer,
JMSLinkProtocol
protocol)
protected
Boolean
usesEncryptedSocket
()
Method Detail
closeConnection
protected
void closeConnection() throws JMSException
(Code)
closeConsumer
protected
void closeConsumer(MessageConsumer consumer) throws JMSException
(Code)
closeContext
protected
void closeContext() throws
NamingException
(Code)
computeCost
protected
int computeCost(
AttributedMessage
message)
(Code)
createDestinationLink
protected
DestinationLink
createDestinationLink(
MessageAddress
address)
(Code)
ensureSession
protected
Session ensureSession()
(Code)
extractDestinationName
protected
String
extractDestinationName(
URI
ref)
(Code)
fillContextProperties
protected
void fillContextProperties(
Map
<
String
,
Object
> properties)
(Code)
findOrMakeNodeServant
protected
void findOrMakeNodeServant()
(Code)
findOrMakeReplySync
final
protected
ReplySync
findOrMakeReplySync()
(Code)
flushObsoleteMessages
protected
void flushObsoleteMessages() throws JMSException
(Code)
getConnection
protected
Connection getConnection()
(Code)
getConsumer
protected
MessageConsumer getConsumer()
(Code)
getContext
protected
Context
getContext()
(Code)
getFactory
protected
ConnectionFactory getFactory()
(Code)
getGenericProducer
protected
MessageProducer getGenericProducer()
(Code)
getMyServantId
protected
String
getMyServantId(
String
node)
(Code)
getProtocolType
protected
String
getProtocolType()
(Code)
getSelector
protected
String
getSelector(
String
myServantId)
(Code)
getServant
protected
Destination getServant()
(Code)
getSession
protected
Session getSession()
(Code)
isServantAlive
protected
boolean isServantAlive()
(Code)
load
public
void load()
(Code)
lookupDestinationInContext
protected
Destination lookupDestinationInContext(
String
destinationName) throws
NamingException
(Code)
makeConnection
protected
Connection makeConnection() throws JMSException
(Code)
makeConnectionFactory
protected
ConnectionFactory makeConnectionFactory() throws
NamingException
(Code)
makeInitialContext
protected
InitialContext
makeInitialContext(
Hashtable
<
String
,
Object
> properties) throws
NamingException
(Code)
makeMessageConsumer
protected
MessageConsumer makeMessageConsumer(Session session, Destination destination,
String
ServantID) throws JMSException
(Code)
makeMessageReceiver
protected
MessageReceiver
makeMessageReceiver(
ReplySync
sync,
MessageDeliverer
deliverer)
(Code)
makeMessageSender
protected
MessageSender
makeMessageSender(
ReplySync
replySync)
(Code)
makeProducer
protected
MessageProducer makeProducer(Destination destination) throws JMSException
(Code)
makeReplySync
protected
ReplySync
makeReplySync()
(Code)
makeServantDestination
protected
Destination makeServantDestination(
String
myServantId) throws JMSException,
NamingException
(Code)
makeSession
protected
Session makeSession() throws JMSException
(Code)
makeSessionExceptionListener
protected
void makeSessionExceptionListener() throws JMSException
(Code)
makeURI
protected
URI
makeURI(
String
myServantId) throws
URISyntaxException
(Code)
onMessage
public
void onMessage(Message msg)
(Code)
rebindDestinationInContext
protected
void rebindDestinationInContext(
String
name, Destination destination) throws
NamingException
(Code)
releaseNodeServant
protected
void releaseNodeServant()
(Code)
remakeNodeServant
protected
void remakeNodeServant()
(Code)
subscribeConsumer
protected
void subscribeConsumer(MessageConsumer consumer,
JMSLinkProtocol
protocol) throws JMSException
(Code)
usesEncryptedSocket
protected
Boolean
usesEncryptedSocket()
(Code)
Methods inherited from
org.cougaar.mts.base.RPCLinkProtocol
public
boolean addressKnown(
MessageAddress
address)
(Code)
(Java Doc)
abstract
protected
int computeCost(
AttributedMessage
message)
(Code)
(Java Doc)
abstract
protected
DestinationLink
createDestinationLink(
MessageAddress
address)
(Code)
(Java Doc)
abstract
protected
void findOrMakeNodeServant()
(Code)
(Java Doc)
public
DestinationLink
getDestinationLink(
MessageAddress
address)
(Code)
(Java Doc)
abstract
protected
String
getProtocolType()
(Code)
(Java Doc)
public
Object
getService(
ServiceBroker
sb,
Object
requestor,
Class
serviceClass)
(Code)
(Java Doc)
public
void ipAddressChanged()
(Code)
(Java Doc)
protected
boolean isServantAlive()
(Code)
(Java Doc)
public
void load()
(Code)
(Java Doc)
final
public
void registerClient(
MessageTransportClient
client)
(Code)
(Java Doc)
abstract
protected
void releaseNodeServant()
(Code)
(Java Doc)
public
void releaseService(
ServiceBroker
sb,
Object
requestor,
Class
serviceClass,
Object
service)
(Code)
(Java Doc)
abstract
protected
void remakeNodeServant()
(Code)
(Java Doc)
final
public
void reregisterClients()
(Code)
(Java Doc)
protected
void setNodeURI(
URI
ref)
(Code)
(Java Doc)
final
public
void unregisterClient(
MessageTransportClient
client)
(Code)
(Java Doc)
abstract
protected
Boolean
usesEncryptedSocket()
(Code)
(Java Doc)
www.java2java.com
|
Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.