Functions — github.com/BrightStarry/RabbitMQ

CodeHub MCPcopy Create free account

hub / github.com/BrightStarry/RabbitMQ / functions

Functions39 in github.com/BrightStarry/RabbitMQ

⨍ Functions 39 ◇ Types & classes 12

↓ 2 callersMethodreceive

src/main/java/com/zx/rabbitmq/base/workQueue/Receive.java:20

↓ 2 callersMethodreceive

(int id, String[] routings)

src/main/java/com/zx/rabbitmq/base/routing/Receive.java:21

↓ 1 callersMethoda

src/main/java/com/zx/rabbitmq/base/rpc/Receive.java:64

↓ 1 callersMethoddoWork

计算任务消息中包含的....的个数.每个"."表示需要消耗1s处理该任务

src/main/java/com/zx/rabbitmq/base/workQueue/Receive.java:123

↓ 1 callersMethodreceive

src/main/java/com/zx/rabbitmq/base/rpc/Receive.java:20

↓ 1 callersMethodreceive

src/main/java/com/zx/rabbitmq/base/publishSubscription/Receive.java:20

↓ 1 callersMethodreceive

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:21

↓ 1 callersMethodsend

src/main/java/com/zx/rabbitmq/base/workQueue/Send.java:20

↓ 1 callersMethodsend

src/main/java/com/zx/rabbitmq/base/rpc/Send.java:23

↓ 1 callersMethodsend

src/main/java/com/zx/rabbitmq/base/publishSubscription/Send.java:23

↓ 1 callersMethodsend

src/main/java/com/zx/rabbitmq/base/hello/Send.java:25

↓ 1 callersMethodsend

src/main/java/com/zx/rabbitmq/base/routing/Send.java:23

MethodcontextLoads

src/test/java/com/zx/rabbitmq/RabbitMqApplicationTests.java:12

MethodhandleAck

(long deliveryTag, boolean multiple)

src/main/java/com/zx/rabbitmq/base/workQueue/Send.java:76

MethodhandleCancel

(String consumerTag)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:93

MethodhandleCancelOk

(String consumerTag)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:88

MethodhandleConnectionRecoveryException

(Connection conn, Throwable exception)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:32

MethodhandleConsumeOk

(String consumerTag)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:83

MethodhandleDelivery

处理交付 ,也就是消费消息 @param consumerTag 消费者标签 @param envelope 信封类,包含了交付者标签(确认了,是每个消费者独立的id,递增,重启后重新累加)/是否重新交付/路由key等信息 @param properties 基本属性 @param body 消息

src/main/java/com/zx/rabbitmq/base/workQueue/Receive.java:60

MethodhandleDelivery

(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)

src/main/java/com/zx/rabbitmq/base/rpc/Send.java:48

MethodhandleDelivery

模拟一个远程过程. 计算完成后.

src/main/java/com/zx/rabbitmq/base/rpc/Receive.java:39

MethodhandleDelivery

(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)

src/main/java/com/zx/rabbitmq/base/publishSubscription/Receive.java:42

MethodhandleDelivery

处理交付 ,也就是消费消息 @param consumerTag 消费者标签 @param envelope 信封类,包含了交付者标签/是否重新交付/路由key等信息 @param properties 基本属性 @param body 消息 @throws IOException

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:77

MethodhandleDelivery

(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)

src/main/java/com/zx/rabbitmq/base/routing/Receive.java:47

MethodhandleNack

(long deliveryTag, boolean multiple)

src/main/java/com/zx/rabbitmq/base/workQueue/Send.java:83

MethodhandleRecoverOk

(String consumerTag)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:98

MethodhandleRecovery

(Recoverable recoverable)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:49

MethodhandleRecoveryStarted

(Recoverable recoverable)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:55

(String[] args)

src/main/java/com/zx/rabbitmq/RabbitMqApplication.java:9

(String[] args)

src/main/java/com/zx/rabbitmq/base/workQueue/Send.java:99

(String[] args)

src/main/java/com/zx/rabbitmq/base/workQueue/Receive.java:129

(String[] args)

src/main/java/com/zx/rabbitmq/base/rpc/Send.java:64

(String[] args)

src/main/java/com/zx/rabbitmq/base/rpc/Receive.java:73

(String[] args)

src/main/java/com/zx/rabbitmq/base/publishSubscription/Send.java:54

(String[] args)

src/main/java/com/zx/rabbitmq/base/publishSubscription/Receive.java:54

(String[] args)

src/main/java/com/zx/rabbitmq/base/hello/Send.java:87

(String[] args)

src/main/java/com/zx/rabbitmq/base/hello/Receive.java:120

(String[] args)

src/main/java/com/zx/rabbitmq/base/routing/Send.java:49

开启两个消费者, 分别订阅 error路由和info/warn路由的消息 @param args @throws IOException @throws TimeoutException

src/main/java/com/zx/rabbitmq/base/routing/Receive.java:65