英文:
How to Route message from file to Azure Event Hub Using JAVA Program
问题
//SimpleRouteBuilderimport org.apache.camel.builder.RouteBuilder;public class SimpleRouteBuilder extends RouteBuilder {@Overridepublic void configure() throws Exception {from("file:d:/InputFolderForCamel").split().tokenize("\n").to("jms:queue:javainuse");}}//MainClassSimpleRouteBuilder routeBuilder = new SimpleRouteBuilder();CamelContext ctx = new DefaultCamelContext();//configure jms componentConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://0.0.0.0:61616");ctx.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));try {ctx.addRoutes(routeBuilder);ctx.start();Thread.sleep(5 * 60 * 1000);ctx.stop();} catch (Exception e) {e.printStackTrace();}
这段代码在使用ActiveMQ上工作得很好。
我想用Azure Event Hub编写相同的Java程序。文件必须由Camel读取并路由到Azure Event Hub。
英文:
//SimpleRouteBuilderimport org.apache.camel.builder.RouteBuilder;public class SimpleRouteBuilder extends RouteBuilder{@Overridepublic void configure() throws Exception {from("file:d:/InputFolderForCamel").split().tokenize("\n").to("jms:queue:javainuse");}//MainClassSimpleRouteBuilder routeBuilder = new SimpleRouteBuilder();CamelContext ctx = new DefaultCamelContext();//configure jms componentConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://0.0.0.0:61616");ctx.addComponent("jms", JmsComponent.jmsComponentAutoAcknowledge(connectionFactory));try {ctx.addRoutes(routeBuilder);ctx.start();Thread.sleep(5 * 60 * 1000);ctx.stop();}catch (Exception e) {e.printStackTrace();}
It is working fine with ActiveMQ.
I would like to write same java program with Azure Event Hub. File must be readed by Camel and routed to Azure Event Hub
答案1
得分: 1
from("file:d:/InputFolderForCamel").split().tokenize("\n").to("azure-eventhubs://[namespace/eventHubName][?options]");URI格式：azure-eventhubs://[命名空间/事件中心名称][?选项]如果您提供了connectionString，则不需要提供namespace和eventHubName，因为这些选项已包含在connectionString中。例如：`azure-eventhubs://camel/camelHub?sharedAccessName={your-SASpolicyName}&sharedAccessKey={your-SASaccessKey}`如果要使用原始连接字符串，格式如下：`azure-eventhubs:?connectionString=Endpoint=sb://{your-namespace-name}.servicebus.windows.net/;SharedAccessKeyName={your-SASpolicyName};SharedAccessKey={your-SASaccessKey};EntityPath={event-hub-name}`您可以从Azure门户获取`sharedAccessName`和`sharedAccessKey`的值 -> 您的事件中心命名空间 -> 'Shared Access Policies' 选项卡。阅读有关Camel事件中心URI的更多信息[此处](https://camel.apache.org/components/latest/azure-eventhubs-component.html#_uri_options)。
英文:
from("file:d:/InputFolderForCamel").split().tokenize("\n").to("azure-eventhubs://[namespace/eventHubName][?options]");
URI FORMAT: azure-eventhubs://[namespace/eventHubName][?options]
In case you supply the connectionString, namespace and eventHubName are not required as these options already included in the connectionString.
For example: azure-eventhubs://camel/camelHub?sharedAccessName={your-SASpolicyName}&sharedAccessKey={your-SASaccessKey}
If you want to use raw connection string, it would be azure-eventhubs:?connectionString=Endpoint=sb://{your-namespace-name}.servicebus.windows.net/;SharedAccessKeyName={your-SASpolicyName};SharedAccessKey={your-SASaccessKey};EntityPath={event-hub-name}
You can obtain sharedAccessName and sharedAccessKey values from Azure portal -> Your Event Hub namespace -> 'Shared Access Policies' blade.
Read more about event hub URI for Camel here.
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论