Skip to content

Commit e24117a

Browse files
duhengluckyduhenglucky
committed
feat(api) polish openmessaging api definition
1 parent e0ea306 commit e24117a

59 files changed

Lines changed: 593 additions & 144 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/PullConsumerApp.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -17,11 +17,11 @@
1717

1818
package io.openmessaging.samples.consumer;
1919

20-
import io.openmessaging.Message;
21-
import io.openmessaging.MessagingAccessPoint;
22-
import io.openmessaging.OMS;
23-
import io.openmessaging.PullConsumer;
24-
import io.openmessaging.TopicPartition;
20+
import io.openmessaging.api.Message;
21+
import io.openmessaging.api.MessagingAccessPoint;
22+
import io.openmessaging.api.OMS;
23+
import io.openmessaging.api.PullConsumer;
24+
import io.openmessaging.api.TopicPartition;
2525
import java.time.Duration;
2626
import java.util.List;
2727
import java.util.Properties;

‎openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/PushConsumerApp.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -17,20 +17,20 @@
1717

1818
package io.openmessaging.samples.consumer;
1919

20-
import io.openmessaging.Action;
21-
import io.openmessaging.ConsumeContext;
22-
import io.openmessaging.Consumer;
23-
import io.openmessaging.Message;
24-
import io.openmessaging.MessageListener;
25-
import io.openmessaging.MessagingAccessPoint;
26-
import io.openmessaging.OMS;
20+
import io.openmessaging.api.Action;
21+
import io.openmessaging.api.ConsumeContext;
22+
import io.openmessaging.api.Consumer;
23+
import io.openmessaging.api.Message;
24+
import io.openmessaging.api.MessageListener;
25+
import io.openmessaging.api.MessagingAccessPoint;
26+
import io.openmessaging.api.OMS;
2727
import java.util.Properties;
2828

2929
public class PushConsumerApp {
3030
public static void main(String[] args) {
3131
//Load and start the vendor implementation from a specific OMS driver URL.
3232
final MessagingAccessPoint messagingAccessPoint =
33-
OMS.getMessagingAccessPoint("oms:rocketmq://localhost:10911/us-east");
33+
OMS.getMessagingAccessPoint("oms:rocketmq://localhost:9876");
3434

3535
Properties properties = new Properties();
3636
final Consumer consumer = messagingAccessPoint.createConsumer(properties);

‎openmessaging-api-samples/src/main/java/io/openmessaging/samples/producer/ProducerApp.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -17,19 +17,19 @@
1717

1818
package io.openmessaging.samples.producer;
1919

20-
import io.openmessaging.Message;
21-
import io.openmessaging.MessagingAccessPoint;
22-
import io.openmessaging.OMS;
23-
import io.openmessaging.OnExceptionContext;
24-
import io.openmessaging.Producer;
25-
import io.openmessaging.SendCallback;
26-
import io.openmessaging.SendResult;
20+
import io.openmessaging.api.Message;
21+
import io.openmessaging.api.MessagingAccessPoint;
22+
import io.openmessaging.api.OMS;
23+
import io.openmessaging.api.OnExceptionContext;
24+
import io.openmessaging.api.Producer;
25+
import io.openmessaging.api.SendCallback;
26+
import io.openmessaging.api.SendResult;
2727
import java.util.Properties;
2828

2929
public class ProducerApp {
3030
public static void main(String[] args) {
3131
final MessagingAccessPoint messagingAccessPoint =
32-
OMS.getMessagingAccessPoint("oms:rocketmq://alice@rocketmq.apache.org/us-east");
32+
OMS.getMessagingAccessPoint("oms:rocketmq://alice@rocketmq.apache.org");
3333

3434
final Producer producer = messagingAccessPoint.createProducer(new Properties());
3535
producer.start();

‎openmessaging-api-samples/src/main/java/io/openmessaging/samples/producer/TransactionProducerApp.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@
1717

1818
package io.openmessaging.samples.producer;
1919

20-
import io.openmessaging.Message;
21-
import io.openmessaging.MessagingAccessPoint;
22-
import io.openmessaging.OMS;
23-
import io.openmessaging.SendResult;
24-
import io.openmessaging.transaction.LocalTransactionChecker;
25-
import io.openmessaging.transaction.LocalTransactionExecutor;
26-
import io.openmessaging.transaction.TransactionProducer;
27-
import io.openmessaging.transaction.TransactionStatus;
20+
import io.openmessaging.api.Message;
21+
import io.openmessaging.api.MessagingAccessPoint;
22+
import io.openmessaging.api.OMS;
23+
import io.openmessaging.api.SendResult;
24+
import io.openmessaging.api.transaction.LocalTransactionChecker;
25+
import io.openmessaging.api.transaction.LocalTransactionExecutor;
26+
import io.openmessaging.api.transaction.TransactionProducer;
27+
import io.openmessaging.api.transaction.TransactionStatus;
2828
import java.util.Properties;
2929

3030
public class TransactionProducerApp {

openmessaging-api/src/main/java/io/openmessaging/Action.java renamed to openmessaging-api/src/main/java/io/openmessaging/api/Action.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
* limitations under the License.
1616
*/
1717

18-
package io.openmessaging;
18+
package io.openmessaging.api;
1919

2020

2121
public enum Action {

openmessaging-api/src/main/java/io/openmessaging/Constants.java renamed to openmessaging-api/src/main/java/io/openmessaging/api/Constants.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.openmessaging;
17+
package io.openmessaging.api;
1818

1919
public class Constants {
2020
public static final String TRANSACTION_ID = "__transactionId__";

openmessaging-api/src/main/java/io/openmessaging/ConsumeContext.java renamed to openmessaging-api/src/main/java/io/openmessaging/api/ConsumeContext.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.openmessaging;
17+
package io.openmessaging.api;
1818

1919
public class ConsumeContext {
2020

openmessaging-api/src/main/java/io/openmessaging/Consumer.java renamed to openmessaging-api/src/main/java/io/openmessaging/api/Consumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.openmessaging;
17+
package io.openmessaging.api;
1818

1919
public interface Consumer extends LifeCycle, Credentials {
2020

openmessaging-api/src/main/java/io/openmessaging/Credentials.java renamed to openmessaging-api/src/main/java/io/openmessaging/api/Credentials.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.openmessaging;
17+
package io.openmessaging.api;
1818
import java.util.Properties;
1919

2020
public interface Credentials {

openmessaging-api/src/main/java/io/openmessaging/ExpressionType.java renamed to openmessaging-api/src/main/java/io/openmessaging/api/ExpressionType.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17-
package io.openmessaging;
17+
package io.openmessaging.api;
1818

1919
public enum ExpressionType {
2020

0 commit comments

Comments
 (0)