| Constructor and Description |
|---|
WonMessageProcessingException(java.lang.String message,
WonMessage wonMessage) |
WonMessageProcessingException(WonMessage wonMessage) |
| Modifier and Type | Method and Description |
|---|---|
static WonMessage |
WonMessageDecoder.decode(org.apache.jena.riot.Lang lang,
java.lang.String message) |
static WonMessage |
WonMessageDecoder.decodeFromDataset(org.apache.jena.query.Dataset message) |
static WonMessage |
WonMessageDecoder.decodeFromJsonLd(java.lang.String message) |
static WonMessage |
WonMessage.deepCopy(WonMessage original) |
WonMessage |
WonMessage.getFocalMessage()
Return the message 'in focus'.
|
WonMessage |
WonMessage.getHeadAndForwarded(boolean recursive) |
static WonMessage |
WonMessage.of(java.util.Collection<WonMessage> messages) |
static WonMessage |
WonMessage.of(org.apache.jena.query.Dataset dataset)
Create a WonMessage object from a dataset that may contain multiple messages.
|
static WonMessage |
WonMessage.of(WonMessage... messages) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Set<WonMessage> |
WonMessage.getAllMessages()
Returns all messages that are present in the dataset that was used to create
this WonMessage object.
|
java.util.Optional<WonMessage> |
WonMessage.getDeliveryChain() |
java.util.Set<WonMessage> |
WonMessage.getForwardedMessages()
Returns all messages forwarded by this message and contained in the complete
dataset.
|
java.util.Optional<WonMessage> |
WonMessage.getHeadMessage() |
java.util.Optional<WonMessage> |
WonMessage.getRemoteResponse()
Returns the remote response to this message, if it is contained in the
complete dataset.
|
java.util.Optional<WonMessage> |
WonMessage.getResponse()
Returns the response to this message, if it is contained in the complete
dataset.
|
| Modifier and Type | Method and Description |
|---|---|
static WonMessage |
WonMessage.deepCopy(WonMessage original) |
static java.lang.String |
WonMessageEncoder.encode(WonMessage message,
org.apache.jena.riot.Lang lang)
Encodes the WonMessage object as serialized RDF in the given language.
|
static org.apache.jena.query.Dataset |
WonMessageEncoder.encodeAsDataset(WonMessage wonMessage) |
static java.lang.String |
WonMessageEncoder.encodeAsJsonLd(WonMessage message) |
static java.util.Optional<java.net.URI> |
WonMessageUtils.getHintTargetAtomURI(WonMessage wonMessage)
Get the targetAtom of a hint (even if it is a SocketHint).
|
static java.net.URI |
WonMessageUtils.getHintTargetAtomURIRequired(WonMessage wonMessage)
Get the targetAtom of a hint (even if it is a SocketHint).
|
static java.util.Optional<java.net.URI> |
WonMessageUtils.getParentAtomUri(WonMessage message,
WonMessageDirection direction)
Returns the atom that this message belongs to.
|
static java.util.Optional<java.net.URI> |
WonMessageUtils.getRecipientAtomURI(WonMessage msg) |
static java.net.URI |
WonMessageUtils.getRecipientAtomURIFromRecipientSocketURI(WonMessage msg) |
static java.net.URI |
WonMessageUtils.getRecipientAtomURIRequired(WonMessage msg) |
static java.util.Optional<java.net.URI> |
WonMessageUtils.getSenderAtomURI(WonMessage msg) |
static java.net.URI |
WonMessageUtils.getSenderAtomURIFromSenderSocketURI(WonMessage msg,
java.net.URI atomUri) |
static java.net.URI |
WonMessageUtils.getSenderAtomURIRequired(WonMessage msg) |
static WonMessage |
WonMessage.of(WonMessage... messages) |
void |
WonMessageDynamicRouter.route(java.net.URI socketType,
java.net.URI direction,
java.net.URI messageType,
WonMessage wonMessage) |
| Modifier and Type | Method and Description |
|---|---|
static WonMessage |
WonMessage.of(java.util.Collection<WonMessage> messages) |
| Modifier and Type | Method and Description |
|---|---|
WonMessage |
TerminalBuilderBase.build() |
WonMessage |
ResponseBuilder.build() |
WonMessage |
HintFeedbackMessageBuilder.build() |
WonMessage |
BuilderBase.build()
Builds the
WonMessage object. |
WonMessage |
WonMessageBuilder.build(org.apache.jena.query.Dataset dataset)
Builds a WonMessage by adding data to the specified dataset.
|
| Modifier and Type | Method and Description |
|---|---|
PARENT |
AgreementBuilderScaffold.accepts(WonMessage... other)
Accept the specified messages.
|
PARENT |
AgreementBuilderScaffold.claims(WonMessage... other)
Claim the specified messages.
|
ConnectionMessageBuilder |
ConnectionMessageBuilder.forward(WonMessage toForward)
Forwards the specified message as part of the message being built.
|
ChangeNotificationBuilder |
ChangeNotificationBuilder.forward(WonMessage toForward)
Forwards the specified message as part of the message being built.
|
PARENT |
AgreementBuilderScaffold.proposes(WonMessage... other)
Propose the specified messages.
|
PARENT |
AgreementBuilderScaffold.proposesToCancel(WonMessage... other)
Propose to cancel the specified messages.
|
PARENT |
SenderSocketBuilder.reactingTo(WonMessage connectMessage)
Assumes that the specified message is a message that we received in a
connection and we want to send a message back.
|
PARENT |
AgreementBuilderScaffold.rejects(WonMessage... other)
Reject the specified messages.
|
ResponseBuilder |
ResponseBuilder.respondingToMessage(WonMessage toRespondTo,
WonMessageDirection direction) |
ResponseBuilder |
ResponseBuilder.respondingToMessageFromExternal(WonMessage toRespondTo) |
ResponseBuilder |
ResponseBuilder.respondingToMessageFromOwner(WonMessage toRespondTo) |
ResponseBuilder |
ResponseBuilder.respondingToMessageFromSystem(WonMessage toRespondTo) |
PARENT |
ModificationBuilderScaffold.retracts(WonMessage... other)
Retract the specified messages.
|
| Modifier and Type | Method and Description |
|---|---|
WonMessage |
WonMessageProcessor.process(WonMessage message) |
| Modifier and Type | Method and Description |
|---|---|
WonMessage |
WonMessageProcessor.process(WonMessage message) |
| Modifier and Type | Method and Description |
|---|---|
WonMessage |
WellformednessCheckingWonMessageProcessor.process(WonMessage message) |
WonMessage |
UriConsistencyCheckingWonMessageProcessor.process(WonMessage message) |
| Modifier and Type | Method and Description |
|---|---|
void |
WellformednessCheckingWonMessageProcessor.checkMessage(WonMessage message) |
WonMessage |
WellformednessCheckingWonMessageProcessor.process(WonMessage message) |
WonMessage |
UriConsistencyCheckingWonMessageProcessor.process(WonMessage message) |
| Modifier and Type | Method and Description |
|---|---|
WonMessage |
WonMessageSender.prepareMessage(WonMessage message)
Signs the message, calculates its messageURI based on content.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WonMessageSender.prepareAndSendMessage(WonMessage message)
Sends the message after signing it and setting its message URI.
|
WonMessage |
WonMessageSender.prepareMessage(WonMessage message)
Signs the message, calculates its messageURI based on content.
|
void |
WonMessageSender.sendMessage(WonMessage message)
Sends the prepared message.
|
| Constructor and Description |
|---|
MessageEvent(java.net.URI parentURI,
WonMessage wonMessage,
MessageContainer messageContainer) |
| Modifier and Type | Method and Description |
|---|---|
void |
MatcherFacingAtomCommunicationService.hint(java.net.URI atomURI,
java.net.URI otherAtom,
double score,
java.net.URI originator,
org.apache.jena.rdf.model.Model content,
WonMessage wonMessage)
Notifies the atom of a matching otherAtom with the specified match score.
|
java.util.Optional<java.net.URI> |
MessageRoutingInfoService.recipientAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoService.recipientNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoService.recipientSocketType(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoService.senderAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoService.senderNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoService.senderSocketType(WonMessage msg) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithoutLookup.recipientAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithLookup.recipientAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceImpl.recipientAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithoutLookup.recipientNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithLookup.recipientNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceImpl.recipientNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithoutLookup.recipientSocketType(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithLookup.recipientSocketType(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceImpl.recipientSocketType(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithoutLookup.senderAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithLookup.senderAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceImpl.senderAtom(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithoutLookup.senderNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithLookup.senderNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceImpl.senderNode(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithoutLookup.senderSocketType(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceWithLookup.senderSocketType(WonMessage msg) |
java.util.Optional<java.net.URI> |
MessageRoutingInfoServiceImpl.senderSocketType(WonMessage msg) |
| Modifier and Type | Method and Description |
|---|---|
static WonMessage |
WonRdfUtils.MessageUtils.copyByDatasetSerialization(WonMessage toWrap) |
| Modifier and Type | Method and Description |
|---|---|
static WonMessage |
WonRdfUtils.MessageUtils.copyByDatasetSerialization(WonMessage toWrap) |
static java.util.List<java.net.URI> |
WonRdfUtils.MessageUtils.getAcceptedEvents(WonMessage wonMessage) |
static java.util.List<java.net.URI> |
WonRdfUtils.MessageUtils.getPreviousMessageUrisIncludingRemote(WonMessage wonMessage)
Returns previous message URIs for local and remote message.
|
static java.util.List<java.net.URI> |
WonRdfUtils.MessageUtils.getProposesEvents(WonMessage wonMessage) |
static java.util.List<java.net.URI> |
WonRdfUtils.MessageUtils.getProposesToCancelEvents(WonMessage wonMessage) |
static java.util.Map<org.apache.jena.rdf.model.Property,java.lang.String> |
WonRdfUtils.MessageUtils.getReviewContent(WonMessage wonMessage)
Returns the whole review content of a WonMessage
|
static java.net.URI |
WonRdfUtils.SocketUtils.getSocket(WonMessage message)
Returns the socket in a connect message.
|
static java.net.URI |
WonRdfUtils.SocketUtils.getTargetSocket(WonMessage message)
Returns the targetSocket in a connect message.
|
static java.lang.String |
WonRdfUtils.MessageUtils.getTextMessage(WonMessage wonMessage)
Returns the first con:text object, or null if none is found. tries the
message, its corresponding remote message, and any forwarded message, if any
of those are contained in the dataset
|
static boolean |
WonRdfUtils.MessageUtils.isProcessingMessage(WonMessage wonMessage) |
| Modifier and Type | Method and Description |
|---|---|
static java.util.Optional<Connection> |
WonLinkedDataUtils.getConnectionForIncomingMessage(WonMessage wonMessage,
LinkedDataSource linkedDataSource) |
static java.util.Optional<Connection> |
WonLinkedDataUtils.getConnectionForOutgoingMessage(WonMessage wonMessage,
LinkedDataSource linkedDataSource) |
static java.util.Optional<java.net.URI> |
WonLinkedDataUtils.getConnectionURIForIncomingMessage(WonMessage wonMessage,
LinkedDataSource linkedDataSource) |
static java.util.Optional<java.net.URI> |
WonLinkedDataUtils.getConnectionURIForOutgoingMessage(WonMessage wonMessage,
LinkedDataSource linkedDataSource) |
Copyright © 2019. All Rights Reserved.