Advertisement
Guest User

Untitled

a guest
Jun 20th, 2019
113
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 5.39 KB | None | 0 0
  1. public class Writer extends AmqpItemWriter<CsvWrapperPojo> {
  2.  
  3. @Autowired
  4. @Qualifier("rabbitTemplate")
  5. private RabbitTemplate rabbitTemplate;
  6.  
  7. public Writer(AmqpTemplate rabbitTemplate) {
  8. super(rabbitTemplate);
  9. // TODO Auto-generated constructor stub
  10. }
  11.  
  12. /*@Autowired
  13. private CSVPostProcess csvPostProcess;*/
  14.  
  15.  
  16. @Override
  17. public void write(final List<? extends CsvWrapperPojo> items) throws Exception {
  18. // TODO Auto-generated method stub
  19.  
  20. for(CsvWrapperPojo item : items){
  21.  
  22.  
  23.  
  24. for(CSVPojo pojo :item.getGeneralPojoList()){
  25.  
  26. rabbitTemplate.convertAndSend("spring-boot-rabbitmq-BulkSolve.async_BulkSolve_Msg", "BulkSolve_GeneralrequestQueue", pojo);
  27. }
  28. for(CSVPojo pojoSummary : item.getSummaryPojoList()){
  29. rabbitTemplate.convertAndSend("spring-boot-rabbitmq-BulkSolve_summary.async_BulkSolve_Msg", "BulkSolve_SummaryrequestQueue", pojoSummary);
  30. }
  31. }
  32.  
  33. }
  34.  
  35.  
  36.  
  37. }```
  38.  
  39. Below is application.properties
  40. ===========================
  41.  
  42. server.port=9060
  43. spring.rabbitmq.dynamic=true
  44. spring.rabbitmq.port=5672
  45. spring.rabbitmq.username=guest
  46. spring.rabbitmq.password=guest
  47. spring.rabbitmq.host=xxx.xx.xx.xxx(Remote machine IP)
  48. spring.batch.job.enabled=false
  49.  
  50.  
  51.  
  52. I have Rabbitmq installed and same queue is available on Remote machine too. But It seems authentication is not happening here. Below is my exception stack trace. Can any one suggest what need to do to publish message to remote machine.
  53.  
  54. ```java.net.SocketException: Socket Closed
  55. at java.net.SocketInputStream.socketRead0(Native Method) ~[na:1.8.0_131]
  56. at java.net.SocketInputStream.socketRead(SocketInputStream.java:116) ~[na:1.8.0_131]
  57. at java.net.SocketInputStream.read(SocketInputStream.java:171) ~[na:1.8.0_131]
  58. at java.net.SocketInputStream.read(SocketInputStream.java:141) ~[na:1.8.0_131]
  59. at java.io.BufferedInputStream.fill(BufferedInputStream.java:246) ~[na:1.8.0_131]
  60. at java.io.BufferedInputStream.read(BufferedInputStream.java:265) ~[na:1.8.0_131]
  61. at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:288) ~[na:1.8.0_131]
  62. at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:91) ~[amqp-client-4.0.3.jar!/:4.0.3]
  63. at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:164) ~[amqp-client-4.0.3.jar!/:4.0.3]
  64. at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:571) ~[amqp-client-4.0.3.jar!/:4.0.3]
  65. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_131]
  66.  
  67. 2019-05-16 15:56:41.683 ERROR 696 --- [nio-9060-exec-1] o.s.batch.core.step.AbstractStep : Encountered an error executing step ETL-CSV in job ETL
  68.  
  69. org.springframework.amqp.AmqpAuthenticationException: com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN. For details see the broker logfile.
  70. at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:65) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  71. at org.springframework.amqp.rabbit.connection.AbstractConnectionFactory.createBareConnection(AbstractConnectionFactory.java:368) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  72. at org.springframework.amqp.rabbit.connection.CachingConnectionFactory.createConnection(CachingConnectionFactory.java:573) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  73. at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:1430) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  74. at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1411) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  75. at org.springframework.amqp.rabbit.core.RabbitTemplate.send(RabbitTemplate.java:712) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  76. at org.springframework.amqp.rabbit.core.RabbitTemplate.convertAndSend(RabbitTemplate.java:780) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  77. at org.springframework.amqp.rabbit.core.RabbitTemplate.convertAndSend(RabbitTemplate.java:776) ~[spring-rabbit-1.7.4.RELEASE.jar!/:na]
  78. at com.comcast.FileProcess.Batch.Writer.write(Writer.java:47) ~[classes!/:0.0.1-SNAPSHOT]
  79. at org.springframework.batch.core.step.item.SimpleChunkProcessor.writeItems(SimpleChunkProcessor.java:175) ~[spring-batch-core-3.0.8.RELEASE.jar!/:3.0.8.RELEASE]
  80. at org.springframework.batch.core.step.item.SimpleChunkProcessor.doWrite(SimpleChunkProcessor.java:151) ~[spring-batch-core-3.0.8.RELEASE.jar!/:3.0.8.RELEASE]
  81. at org.springframework.batch.core.step.item.SimpleChunkProcessor.write(SimpleChunkProcessor.java:274) ~[spring-batch-core-3.0.8.RELEASE.jar!/:3.0.8.RELEASE]
  82. at org.springframework.batch.core.step.item.SimpleChunkProcessor.process(SimpleChunkProcessor.java:199) ~[spring-batch-core-3.0.8.RELEASE.jar!/:3.0.8.RELEASE]
  83. at org.springframework.batch.core.step.item.ChunkOrientedTasklet.execute(ChunkOrientedTasklet.java:75) ~[spring-batch-core-3.0.8.RELEASE.jar!/:3.0.8.RELEASE]
  84. at org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.doInTransaction(TaskletStep.java:406) ~[spring-batch-core-3.0.8.RELEASE.jar!/:3.0.8.RELEASE]
  85. at org.springframework.batch.core.step.tasklet.TaskletStep$ChunkTransactionCallback.doInTransaction(TaskletStep.java:330) ~[spring-batch-core-3.0.8.RELEASE.jar!/:3.0.8.RELEASE]```
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement