Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/streadway/amqp
/ functions
Functions
616 in github.com/streadway/amqp
⨍
Functions
616
◇
Types & classes
119
Function
Example
This exports a Session object that wraps this library. It automatically reconnects when the connection fails, and blocks all pushes until the connecti
example_client_test.go:22
Function
ExampleChannel_Confirm_bridge
()
examples_test.go:107
Function
ExampleChannel_Consume
()
examples_test.go:210
Function
ExampleChannel_Publish
()
examples_test.go:328
Function
ExampleConfig_timeout
()
examples_test.go:15
Function
ExampleConnection_NotifyBlocked
()
examples_test.go:377
Function
ExampleConnection_reconnect
()
reconnect_test.go:45
Function
ExampleDialTLS
()
examples_test.go:28
Method
ExchangeBind
* ExchangeBind binds an exchange to another exchange to create inter-exchange routing topologies on the server. This can decouple the private topolog
channel.go:1245
Method
ExchangeUnbind
* ExchangeUnbind unbinds the destination exchange from the source exchange on the server by removing the routing key between them. This is the invers
channel.go:1276
Method
Fieldsets
Groups the fields so that the right encoder/decoder can be called
spec/gen.go:377
Function
Fuzz
(data []byte)
fuzz.go:7
Method
Generate
(r *rand.Rand, _ int)
integration_test.go:740
Method
Generate
(r *rand.Rand, _ int)
integration_test.go:754
Method
HasField
(field string, method Method)
spec/gen.go:420
Method
HasType
(typ string, method Method)
spec/gen.go:410
Method
IsError
()
spec/gen.go:353
Method
IsSoftError
()
spec/gen.go:357
Method
Less
(i, j int)
types.go:261
Method
Mechanism
Mechanism returns "PLAIN"
auth.go:26
Method
Mechanism
Mechanism returns "AMQPLAIN"
auth.go:42
Method
Nack
* Nack negatively acknowledges a delivery by its delivery tag. Prefer this method to notify the server that you were not able to process this deliver
channel.go:1567
Method
Nack
* Nack negatively acknowledge the delivery of message(s) identified by the delivery tag from either the client or server. When multiple is true, nack
delivery.go:168
Method
Partial
(prefix string, fields []fieldset)
spec/gen.go:361
Method
Pop
()
types.go:264
Method
Publish
publish increments the publishing counter
confirms.go:31
Method
Push
(tag interface{})
types.go:263
Method
QueueUnbind
* QueueUnbind removes a binding between an exchange and queue matching the key and arguments. It is possible to send and empty string for the exchang
channel.go:924
Method
Read
(p []byte)
shared_test.go:39
Method
Reject
* Reject negatively acknowledges a delivery by its delivery tag. Prefer Nack over Reject when communicating with a RabbitMQ server because you can Na
channel.go:1585
Method
Reject
* Reject delegates a negatively acknowledgement through the Acknowledger interface. When requeue is true, queue this message to be delivered to a con
delivery.go:143
Method
Response
Response returns the null character delimited encoding for the SASL PLAIN Mechanism.
auth.go:31
Method
Response
Response returns the null character delimited encoding for the SASL PLAIN Mechanism.
auth.go:47
Method
Stream
Stream will continuously put queue items on the channel. It is required to call delivery.Ack when it has been successfully processed, or delivery.Nack
example_client_test.go:256
Method
String
String returns a string describing the contents of the allocator like "allocator[low..high] reserved..until" O(N) where N is high-low
allocator.go:40
Method
StructName
(parts ...string)
spec/gen.go:486
Method
Swap
(i, j int)
types.go:262
Method
Tag
(d Domain)
spec/gen.go:472
Function
TestAckZeroValueAcknowledgerDoesNotPanic
A closed delivery chan could produce zero value. Ack/Nack/Reject on these deliveries can produce a nil pointer panic. Instead return an error when t
delivery_test.go:14
Function
TestAllocatorFirstShouldBeTheLow
(t *testing.T)
allocator_test.go:8
Function
TestAllocatorReleasesKeepUpWithAllocationsForAllSizes
(t *testing.T)
allocator_test.go:74
Function
TestAllocatorShouldBeBoundByHigh
(t *testing.T)
allocator_test.go:19
Function
TestAllocatorShouldReuseReleased
(t *testing.T)
allocator_test.go:48
Function
TestAllocatorStringShouldIncludeAllocatedRanges
(t *testing.T)
allocator_test.go:33
Function
TestChannelCounterShouldNotPanicIssue136
https://github.com/streadway/amqp/issues/136
integration_test.go:1551
Function
TestChannelExceptionWithCloseIssue43
https://github.com/streadway/amqp/issues/43
integration_test.go:1441
Function
TestChannelOpen
(t *testing.T)
client_test.go:261
Function
TestChannelOpenOnAClosedConnectionFails
(t *testing.T)
connection_test.go:39
Function
TestChannelOpenOnAClosedConnectionFails_ReleasesAllocatedChannel
TestChannelOpenOnAClosedConnectionFails_ReleasesAllocatedChannel ensures the channel allocated is released if opening the channel fails.
connection_test.go:51
Function
TestChannelReturnsCloseRace
TestChannelReturnsCloseRace ensures that receiving a basicReturn frame and sending the notification to the bound channel does not race with channel.sh
client_test.go:634
Function
TestConcurrentChannelAndConnectionClose
(t *testing.T)
integration_test.go:1751
Function
TestConcurrentClose
(t *testing.T)
connection_test.go:121
Function
TestConfirmMixedResequences
(t *testing.T)
confirms_test.go:45
Function
TestConfirmMultipleOrdersDeliveryTags
(t *testing.T)
client_test.go:336
Function
TestConfirmMultipleResequences
(t *testing.T)
confirms_test.go:79
Function
TestConfirmOneResequences
(t *testing.T)
confirms_test.go:8
Function
TestConfirmsIsThreadSafe
(t *testing.T)
confirms_test.go:121
Function
TestConsumerCancelNotification
(t *testing.T)
integration_test.go:1713
Function
TestCorruptedMessageIssue7
https://github.com/streadway/amqp/issues/7
integration_test.go:1494
Function
TestCustomClientProperties
(t *testing.T)
client_test.go:222
Function
TestDeadlockConsumerIssue48
https://github.com/streadway/amqp/issues/48
integration_test.go:1356
Function
TestDeclareArgsRejectToDeadLetterQueue
Sets up the topology where rejected messages will be forwarded to a fanout exchange, with a single queue bound. Relates to https://github.com/streadw
integration_test.go:1279
Function
TestDeclareArgsXMessageTTL
Declares a queue with the x-message-ttl extension to exercise integer serialization. Relates to https://github.com/streadway/amqp/issues/60
integration_test.go:1260
Function
TestDefaultClientProperties
(t *testing.T)
client_test.go:197
Function
TestDefaultConnectionLocale
(t *testing.T)
connection_test.go:31
Function
TestExchangeDeclarePrecondition
(t *testing.T)
integration_test.go:1576
Function
TestExchangePassiveOnMissingExchangeShouldError
https://github.com/streadway/amqp/issues/94
integration_test.go:121
Function
TestGeneratedUniqueConsumerTagDoesNotExceedMaxLength
(t *testing.T)
consumers_test.go:8
Function
TestGoFuzzCrashers
(t *testing.T)
read_test.go:8
Function
TestIntegrationBasicQueueOperations
(t *testing.T)
integration_test.go:298
Function
TestIntegrationCancel
(t *testing.T)
integration_test.go:1134
Function
TestIntegrationChannelClosing
(t *testing.T)
integration_test.go:445
Function
TestIntegrationChannelIDsExhausted
(t *testing.T)
integration_test.go:425
Function
TestIntegrationConfirm
(t *testing.T)
integration_test.go:1163
Function
TestIntegrationConnectionNegotiatesClientMaxChannels
(t *testing.T)
integration_test.go:411
Function
TestIntegrationConnectionNegotiatesMaxChannels
(t *testing.T)
integration_test.go:397
Function
TestIntegrationConsumeCancel
(t *testing.T)
integration_test.go:703
Function
TestIntegrationConsumeFlow
(t *testing.T)
integration_test.go:634
Function
TestIntegrationExchange
(t *testing.T)
integration_test.go:186
Function
TestIntegrationExchangeDeclarePassiveOnDeclaredShouldNotError
https://github.com/streadway/amqp/issues/94
integration_test.go:147
Function
TestIntegrationGetEmpty
(t *testing.T)
integration_test.go:1024
Function
TestIntegrationGetOk
(t *testing.T)
integration_test.go:998
Function
TestIntegrationHighChannelChurnInTightLoop
(t *testing.T)
integration_test.go:50
Function
TestIntegrationLocalAddr
(t *testing.T)
integration_test.go:98
Function
TestIntegrationMeaningfulChannelErrors
(t *testing.T)
integration_test.go:519
Function
TestIntegrationNonBlockingClose
https://github.com/streadway/amqp/issues/6
integration_test.go:558
Function
TestIntegrationOpenClose
(t *testing.T)
integration_test.go:28
Function
TestIntegrationOpenCloseChannel
(t *testing.T)
integration_test.go:38
Function
TestIntegrationOpenConfig
(t *testing.T)
integration_test.go:64
Function
TestIntegrationOpenConfigWithNetDial
(t *testing.T)
integration_test.go:81
Function
TestIntegrationPassiveQueue
https://github.com/streadway/amqp/issues/94
integration_test.go:250
Function
TestIntegrationPublishConsume
(t *testing.T)
integration_test.go:605
Function
TestIntegrationPublishFlow
This test is driven by a private API to simulate the server sending a channelFlow message
integration_test.go:697
Function
TestIntegrationQueueDeclarePassiveOnMissingExchangeShouldError
https://github.com/streadway/amqp/issues/94
integration_test.go:225
Function
TestIntegrationRecoverNotImplemented
(t *testing.T)
integration_test.go:680
Function
TestIntegrationReturn
(t *testing.T)
integration_test.go:1107
Function
TestIntegrationTxCommit
(t *testing.T)
integration_test.go:1045
Function
TestIntegrationTxRollback
(t *testing.T)
integration_test.go:1076
Function
TestIsClosed
TestIsClosed will test the public method IsClosed on a connection.
connection_test.go:183
Function
TestLeakClosedConsumersIssue264
TestLeakClosedConsumersIssue264 ensures that closing a consumer with prefetched messages does not leak the buffering goroutine.
client_test.go:661
← previous
next →
201–300 of 616, ranked by callers