37
37
* of a {@code MessagingAccessPoint}. An instance of {@code Producer} is
38
38
* created by calling the {@link MessagingAccessPoint#createProducer()} method.
39
39
* It provides various {@code send} methods to send a message to a specified destination.
40
- * A destination can be a {@link MessageHeaderBuiltinKeys #Topic} or a {@link MessageHeaderBuiltinKeys #Queue}.
40
+ * A destination can be a {@link Message.BuiltinKeys #Topic} or a {@link Message.BuiltinKeys #Queue}.
41
41
* <p>
42
- *
43
42
* {@link Producer#send(Message)} means send a message to destination synchronously,
44
43
* the calling thread will block until the send request complete.
45
44
* <p>
@@ -68,13 +67,13 @@ public interface Producer extends MessageFactory, ServiceLifecycle {
68
67
* <li> {@link OMSBuiltinKeys#OPERATION_TIMEOUT}, the default timeout period for operations of {@code Producer}.
69
68
* </ul>
70
69
*
71
- * @return the attributes
70
+ * @return the properties
72
71
*/
73
72
KeyValue properties ();
74
73
75
74
/**
76
75
* Sends a message to the specified destination synchronously, the destination should be preset to
77
- * {@link MessageHeaderBuiltinKeys }, other header fields as well.
76
+ * {@link Message#sysHeaders() }, other header fields as well.
78
77
*
79
78
* @param message a message will be sent
80
79
* @return the successful {@code SendResult}
@@ -86,7 +85,7 @@ public interface Producer extends MessageFactory, ServiceLifecycle {
86
85
87
86
/**
88
87
* Sends a message to the specified destination synchronously, using the specified attributes, the destination
89
- * should be preset to {@link MessageHeaderBuiltinKeys }, other header fields as well.
88
+ * should be preset to {@link Message#sysHeaders() }, other header fields as well.
90
89
*
91
90
* @param message a message will be sent
92
91
* @param properties the specified attributes
@@ -101,7 +100,7 @@ public interface Producer extends MessageFactory, ServiceLifecycle {
101
100
102
101
/**
103
102
* Sends a message to the specified destination asynchronously, the destination should be preset to
104
- * {@link MessageHeaderBuiltinKeys }, other header fields as well.
103
+ * {@link Message#sysHeaders() }, other header fields as well.
105
104
* <p>
106
105
* The returned {@code Promise} will have the result once the operation completes, and the registered
107
106
* {@code FutureListener} will be notified, either because the operation was successful or because of an error.
@@ -115,7 +114,7 @@ public interface Producer extends MessageFactory, ServiceLifecycle {
115
114
116
115
/**
117
116
* Sends a message to the specified destination asynchronously, using the specified attributes, the destination
118
- * should be preset to {@link MessageHeaderBuiltinKeys }, other header fields as well.
117
+ * should be preset to {@link Message#sysHeaders() }, other header fields as well.
119
118
* <p>
120
119
* The returned {@code Promise} will have the result once the operation completes, and the registered
121
120
* {@code FutureListener} will be notified, either because the operation was successful or because of an error.
@@ -130,7 +129,7 @@ public interface Producer extends MessageFactory, ServiceLifecycle {
130
129
131
130
/**
132
131
* Sends a message to the specified destination in one way, the destination should be preset to
133
- * {@link MessageHeaderBuiltinKeys }, other header fields as well.
132
+ * {@link Message#sysHeaders() }, other header fields as well.
134
133
* <p>
135
134
* There is no {@code Promise} related or {@code RuntimeException} thrown. The calling thread doesn't
136
135
* care about the send result and also have no context to get the result.
@@ -141,7 +140,7 @@ public interface Producer extends MessageFactory, ServiceLifecycle {
141
140
142
141
/**
143
142
* Sends a message to the specified destination in one way, using the specified attributes, the destination
144
- * should be preset to {@link MessageHeaderBuiltinKeys }, other header fields as well.
143
+ * should be preset to {@link Message#sysHeaders() }, other header fields as well.
145
144
* <p>
146
145
* There is no {@code Promise} related or {@code RuntimeException} thrown. The calling thread doesn't
147
146
* care about the send result and also have no context to get the result.
0 commit comments