blob: ebaec134b00010eb698b704fff9aabf8b8c5fae3 [file] [log] [blame]
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
using System.Text;
using System.Threading.Tasks;
using NLog;
using Org.Apache.Rocketmq;
namespace examples
{
internal static class ProducerTransactionMessageExample
{
private static readonly Logger Logger = MqLogManager.Instance.GetCurrentClassLogger();
private class TransactionChecker : ITransactionChecker
{
public TransactionResolution Check(MessageView messageView)
{
Logger.Info("Receive transaction check, messageId={}", messageView.MessageId);
return TransactionResolution.Commit;
}
}
internal static async Task QuickStart()
{
// Enable the switch if you use .NET Core 3.1 and want to disable TLS/SSL.
// AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true);
const string accessKey = "yourAccessKey";
const string secretKey = "yourSecretKey";
// Credential provider is optional for client configuration.
var credentialsProvider = new StaticSessionCredentialsProvider(accessKey, secretKey);
const string endpoints = "foobar.com:8080";
var clientConfig = new ClientConfig.Builder()
.SetEndpoints(endpoints)
.SetCredentialsProvider(credentialsProvider)
.Build();
const string topic = "yourTransactionTopic";
// In most case, you don't need to create too many producers, single pattern is recommended.
// Producer here will be closed automatically.
var producer = await new Producer.Builder()
// Set the topic name(s), which is optional but recommended.
// It makes producer could prefetch the topic route before message publishing.
.SetTopics(topic)
.SetClientConfig(clientConfig)
.SetTransactionChecker(new TransactionChecker())
.Build();
var transaction = producer.BeginTransaction();
// Define your message body.
var bytes = Encoding.UTF8.GetBytes("foobar");
const string tag = "yourMessageTagA";
var message = new Message.Builder()
.SetTopic(topic)
.SetBody(bytes)
.SetTag(tag)
// You could set multiple keys for the single message actually.
.SetKeys("yourMessageKey-7044358f98fc")
.Build();
var sendReceipt = await producer.Send(message, transaction);
Logger.Info("Send transaction message successfully, messageId={}", sendReceipt.MessageId);
// Commit the transaction.
transaction.Commit();
// Or rollback the transaction.
// transaction.Rollback();
// Close the producer if you don't need it anymore.
await producer.DisposeAsync();
}
}
}