[27/50] [abbrv] qpid-proton git commit: PROTON-827: Concurrent Go API for proton.

[ac...@apache.org]

http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/bd3fb337/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
----------------------------------------------------------------------
diff --git a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a b/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
deleted file mode 100644
index 3bafe9c..0000000
--- a/proton-c/bindings/go/pkg/linux_amd64/qpid.apache.org/proton/go/messaging.a
+++ /dev/null
@@ -1,1100 +0,0 @@
-!<arch>
-__.PKGDEF       0           0     0     644     63393     `
-go object linux amd64 go1.4.2 X:precisestack
-
-$$
-package messaging
-	import net "net"
-	import runtime "runtime"
-	import time "time"
-	import io "io"
-	import cgo "runtime/cgo"
-	import amqp "qpid.apache.org/proton/go/amqp"
-	import syscall "syscall"
-	import fmt "fmt"
-	import internal "qpid.apache.org/proton/go/internal"
-	import reflect "reflect"
-	import reactor "qpid.apache.org/proton/go/reactor"
-	import unsafe "unsafe"
-	var @"".Closed error
-	type @"".Endpoint interface { Close(? error); Error() (? error); Open() (? error); String() (? string) }
-	type @"".Link interface { Close(? error); Error() (? error); IsOpen() (? bool); IsReceiver() (? bool); IsSender() (? bool); Name() (? string); Open() (? error); SetName(? string); SetSource(? string); SetTarget(? string); Source() (? string); String() (? string); Target() (? string) }
-	type @"time".zone struct { @"time".name string; @"time".offset int; @"time".isDST bool }
-	type @"time".zoneTrans struct { @"time".when int64; @"time".index uint8; @"time".isstd bool; @"time".isutc bool }
-	type @"time".Location struct { @"time".name string; @"time".zone []@"time".zone; @"time".tx []@"time".zoneTrans; @"time".cacheStart int64; @"time".cacheEnd int64; @"time".cacheZone *@"time".zone }
-	func (@"time".l·2 *@"time".Location "esc:0x0") String () (? string)
-	func (@"time".l·2 *@"time".Location "esc:0x0") @"time".firstZoneUsed () (? bool)
-	func (@"time".l·2 *@"time".Location "esc:0x2") @"time".get () (? *@"time".Location)
-	func (@"time".l·6 *@"time".Location "esc:0x1") @"time".lookup (@"time".sec·7 int64) (@"time".name·1 string, @"time".offset·2 int, @"time".isDST·3 bool, @"time".start·4 int64, @"time".end·5 int64)
-	func (@"time".l·2 *@"time".Location "esc:0x0") @"time".lookupFirstZone () (? int)
-	func (@"time".l·4 *@"time".Location "esc:0x0") @"time".lookupName (@"time".name·5 string "esc:0x0", @"time".unix·6 int64) (@"time".offset·1 int, @"time".isDST·2 bool, @"time".ok·3 bool)
-	type @"time".Duration int64
-	func (@"time".d·2 @"time".Duration) Hours () (? float64) { var @"time".hour·3 @"time".Duration; ; @"time".hour·3 = @"time".d·2 / @"time".Duration(0x34630B8A000); var @"time".nsec·4 @"time".Duration; ; @"time".nsec·4 = @"time".d·2 % @"time".Duration(0x34630B8A000); return float64(@"time".hour·3) + float64(@"time".nsec·4) * 0x9C5FFF26ED75Fp-93 }
-	func (@"time".d·2 @"time".Duration) Minutes () (? float64) { var @"time".min·3 @"time".Duration; ; @"time".min·3 = @"time".d·2 / @"time".Duration(0xDF8475800); var @"time".nsec·4 @"time".Duration; ; @"time".nsec·4 = @"time".d·2 % @"time".Duration(0xDF8475800); return float64(@"time".min·3) + float64(@"time".nsec·4) * 0x9299FF347E9E9p-87 }
-	func (@"time".d·2 @"time".Duration) Nanoseconds () (? int64) { return int64(@"time".d·2) }
-	func (@"time".d·2 @"time".Duration) Seconds () (? float64) { var @"time".sec·3 @"time".Duration; ; @"time".sec·3 = @"time".d·2 / @"time".Duration(0x3B9ACA00); var @"time".nsec·4 @"time".Duration; ; @"time".nsec·4 = @"time".d·2 % @"time".Duration(0x3B9ACA00); return float64(@"time".sec·3) + float64(@"time".nsec·4) * 0x112E0BE826D695p-82 }
-	func (@"time".d·2 @"time".Duration) String () (? string)
-	type @"time".Month int
-	func (@"time".m·2 @"time".Month) String () (? string) { return @"time".months[@"time".m·2 - @"time".Month(0x1)] }
-	type @"time".Weekday int
-	func (@"time".d·2 @"time".Weekday) String () (? string) { return @"time".days[@"time".d·2] }
-	type @"time".Time struct { @"time".sec int64; @"time".nsec int32; @"time".loc *@"time".Location }
-	func (@"time".t·2 @"time".Time "esc:0x2") Add (@"time".d·3 @"time".Duration) (? @"time".Time)
-	func (@"time".t·2 @"time".Time "esc:0x2") AddDate (@"time".years·3 int, @"time".months·4 int, @"time".days·5 int) (? @"time".Time)
-	func (@"time".t·2 @"time".Time "esc:0x0") After (@"time".u·3 @"time".Time "esc:0x0") (? bool) { return @"time".t·2.@"time".sec > @"time".u·3.@"time".sec || @"time".t·2.@"time".sec == @"time".u·3.@"time".sec && @"time".t·2.@"time".nsec > @"time".u·3.@"time".nsec }
-	func (@"time".t·2 @"time".Time "esc:0x0") Before (@"time".u·3 @"time".Time "esc:0x0") (? bool) { return @"time".t·2.@"time".sec < @"time".u·3.@"time".sec || @"time".t·2.@"time".sec == @"time".u·3.@"time".sec && @"time".t·2.@"time".nsec < @"time".u·3.@"time".nsec }
-	func (@"time".t·4 @"time".Time "esc:0x0") Clock () (@"time".hour·1 int, @"time".min·2 int, @"time".sec·3 int)
-	func (@"time".t·4 @"time".Time "esc:0x0") Date () (@"time".year·1 int, @"time".month·2 @"time".Month, @"time".day·3 int)
-	func (@"time".t·2 @"time".Time "esc:0x0") Day () (? int)
-	func (@"time".t·2 @"time".Time "esc:0x0") Equal (@"time".u·3 @"time".Time "esc:0x0") (? bool) { return @"time".t·2.@"time".sec == @"time".u·3.@"time".sec && @"time".t·2.@"time".nsec == @"time".u·3.@"time".nsec }
-	func (@"time".t·2 @"time".Time "esc:0x0") Format (@"time".layout·3 string "esc:0x0") (? string)
-	func (@"time".t·2 *@"time".Time "esc:0x0") GobDecode (@"time".data·3 []byte "esc:0x0") (? error)
-	func (@"time".t·3 @"time".Time "esc:0x0") GobEncode () (? []byte, ? error)
-	func (@"time".t·2 @"time".Time "esc:0x0") Hour () (? int)
-	func (@"time".t·3 @"time".Time "esc:0x0") ISOWeek () (@"time".year·1 int, @"time".week·2 int)
-	func (@"time".t·2 @"time".Time "esc:0x2") In (@"time".loc·3 *@"time".Location "esc:0x2") (? @"time".Time)
-	func (@"time".t·2 @"time".Time "esc:0x0") IsZero () (? bool) { return @"time".t·2.@"time".sec == 0x0 && @"time".t·2.@"time".nsec == 0x0 }
-	func (@"time".t·2 @"time".Time "esc:0x2") Local () (? @"time".Time) { @"time".t·2.@"time".loc = @"time".Local; return @"time".t·2 }
-	func (@"time".t·2 @"time".Time "esc:0x2") Location () (? *@"time".Location) { var @"time".l·3 *@"time".Location; ; @"time".l·3 = @"time".t·2.@"time".loc; if @"time".l·3 == nil { @"time".l·3 = @"time".UTC }; return @"time".l·3 }
-	func (@"time".t·3 @"time".Time "esc:0x0") MarshalBinary () (? []byte, ? error)
-	func (@"time".t·3 @"time".Time "esc:0x0") MarshalJSON () (? []byte, ? error)
-	func (@"time".t·3 @"time".Time "esc:0x0") MarshalText () (? []byte, ? error)
-	func (@"time".t·2 @"time".Time "esc:0x0") Minute () (? int)
-	func (@"time".t·2 @"time".Time "esc:0x0") Month () (? @"time".Month)
-	func (@"time".t·2 @"time".Time "esc:0x0") Nanosecond () (? int) { return int(@"time".t·2.@"time".nsec) }
-	func (@"time".t·2 @"time".Time "esc:0x2") Round (@"time".d·3 @"time".Duration) (? @"time".Time)
-	func (@"time".t·2 @"time".Time "esc:0x0") Second () (? int)
-	func (@"time".t·2 @"time".Time "esc:0x0") String () (? string)
-	func (@"time".t·2 @"time".Time "esc:0x0") Sub (@"time".u·3 @"time".Time "esc:0x0") (? @"time".Duration)
-	func (@"time".t·2 @"time".Time "esc:0x2") Truncate (@"time".d·3 @"time".Duration) (? @"time".Time)
-	func (@"time".t·2 @"time".Time "esc:0x2") UTC () (? @"time".Time) { @"time".t·2.@"time".loc = @"time".UTC; return @"time".t·2 }
-	func (@"time".t·2 @"time".Time "esc:0x0") Unix () (? int64) { return @"time".t·2.@"time".sec + -0xE7791F700 }
-	func (@"time".t·2 @"time".Time "esc:0x0") UnixNano () (? int64) { return (@"time".t·2.@"time".sec + -0xE7791F700) * 0x3B9ACA00 + int64(@"time".t·2.@"time".nsec) }
-	func (@"time".t·2 *@"time".Time "esc:0x0") UnmarshalBinary (@"time".data·3 []byte "esc:0x0") (? error)
-	func (@"time".t·2 *@"time".Time "esc:0x0") UnmarshalJSON (@"time".data·3 []byte "esc:0x0") (@"time".err·1 error)
-	func (@"time".t·2 *@"time".Time "esc:0x0") UnmarshalText (@"time".data·3 []byte "esc:0x0") (@"time".err·1 error)
-	func (@"time".t·2 @"time".Time "esc:0x0") Weekday () (? @"time".Weekday)
-	func (@"time".t·2 @"time".Time "esc:0x0") Year () (? int)
-	func (@"time".t·2 @"time".Time "esc:0x0") YearDay () (? int)
-	func (@"time".t·3 @"time".Time "esc:0x0") Zone () (@"time".name·1 string, @"time".offset·2 int)
-	func (@"time".t·2 @"time".Time "esc:0x0") @"time".abs () (? uint64)
-	func (@"time".t·5 @"time".Time "esc:0x0") @"time".date (@"time".full·6 bool) (@"time".year·1 int, @"time".month·2 @"time".Month, @"time".day·3 int, @"time".yday·4 int)
-	func (@"time".t·4 @"time".Time "esc:0x1") @"time".locabs () (@"time".name·1 string, @"time".offset·2 int, @"time".abs·3 uint64)
-	type @"qpid.apache.org/proton/go/amqp".Message interface { Address() (? string); Annotations() (? *map[string]interface {}); Body() (? interface {}); ContentEncoding() (? string); ContentType() (? string); CorrelationId() (? interface {}); CreationTime() (? @"time".Time); DeliveryCount() (? uint32); Durable() (? bool); Encode(@"qpid.apache.org/proton/go/amqp".buffer []byte) (? []byte, ? error); ExpiryTime() (? @"time".Time); FirstAcquirer() (? bool); GroupId() (? string); GroupSequence() (? int32); Inferred() (? bool); Instructions() (? *map[string]interface {}); MessageId() (? interface {}); Priority() (? uint8); Properties() (? *map[string]interface {}); ReplyTo() (? string); ReplyToGroupId() (? string); SetAddress(? string); SetBody(? interface {}); SetContentEncoding(? string); SetContentType(? string); SetCorrelationId(? interface {}); SetCreationTime(? @"time".Time); SetDeliveryCount(? uint32); SetDurable(? bool); SetExpiryTime(? @"time".Time); SetFirstAcquirer(? bool); SetGr
 oupId(? string); SetGroupSequence(? int32); SetInferred(? bool); SetMessageId(? interface {}); SetPriority(? uint8); SetReplyTo(? string); SetReplyToGroupId(? string); SetSubject(? string); SetTTL(? @"time".Duration); SetUserId(? string); Subject() (? string); TTL() (? @"time".Duration); UserId() (? string) }
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_delivery_t struct {}
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_link_t struct {}
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_condition_t struct {}
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_data_t struct {}
-	type @"qpid.apache.org/proton/go/reactor".Data struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_data_t }
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Clear ()
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Error () (? error)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Free ()
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Data "esc:0x2") Pointer () (? @"unsafe".Pointer) { return @"unsafe".Pointer(@"qpid.apache.org/proton/go/reactor".d·2.@"qpid.apache.org/proton/go/reactor".pn) }
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Data "esc:0x0") Rewind ()
-	type @"qpid.apache.org/proton/go/reactor".Condition struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_condition_t }
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Clear ()
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Description () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Error () (? error)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Info () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".c·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") IsRedirect () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") IsSet () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") Name () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") RedirectHost () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") RedirectPort () (? int)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") SetDescription (@"qpid.apache.org/proton/go/reactor".description·3 string "esc:0x0") (? int)
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") SetError (@"qpid.apache.org/proton/go/reactor".err·2 error)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Condition "esc:0x0") SetName (@"qpid.apache.org/proton/go/reactor".name·3 string "esc:0x0") (? int)
-	type @"qpid.apache.org/proton/go/reactor".State uint8
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".State) Is (@"qpid.apache.org/proton/go/reactor".bits·3 @"qpid.apache.org/proton/go/reactor".State) (? bool) { return @"qpid.apache.org/proton/go/reactor".s·2 & @"qpid.apache.org/proton/go/reactor".bits·3 != @"qpid.apache.org/proton/go/reactor".State(0x0) }
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".State) Local () (? @"qpid.apache.org/proton/go/reactor".State) { return @"qpid.apache.org/proton/go/reactor".State(@"qpid.apache.org/proton/go/reactor".s·2 & @"qpid.apache.org/proton/go/reactor".State(0x7)) }
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".State) Remote () (? @"qpid.apache.org/proton/go/reactor".State) { return @"qpid.apache.org/proton/go/reactor".State(@"qpid.apache.org/proton/go/reactor".s·2 & @"qpid.apache.org/proton/go/reactor".State(0x38)) }
-	type @"qpid.apache.org/proton/go/reactor".RcvSettleMode uint32
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".RcvSettleMode) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".SndSettleMode uint32
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".SndSettleMode) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_terminus_t struct {}
-	type @"qpid.apache.org/proton/go/reactor".Durability uint32
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Durability) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".ExpiryPolicy uint32
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".ExpiryPolicy) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".DistributionMode uint32
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".DistributionMode) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".TerminusType uint32
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".TerminusType) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".Terminus struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_terminus_t }
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Address () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Capabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Copy (@"qpid.apache.org/proton/go/reactor".src·3 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Durability () (? @"qpid.apache.org/proton/go/reactor".Durability)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") ExpiryPolicy () (? @"qpid.apache.org/proton/go/reactor".ExpiryPolicy)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Filter () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") IsDynamic () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".t·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Outcomes () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Properties () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetAddress (@"qpid.apache.org/proton/go/reactor".address·3 string "esc:0x0") (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetDistributionMode (@"qpid.apache.org/proton/go/reactor".mode·3 @"qpid.apache.org/proton/go/reactor".DistributionMode) (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetDurability (@"qpid.apache.org/proton/go/reactor".durability·3 @"qpid.apache.org/proton/go/reactor".Durability) (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetDynamic (@"qpid.apache.org/proton/go/reactor".dynamic·3 bool) (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetExpiryPolicy (@"qpid.apache.org/proton/go/reactor".policy·3 @"qpid.apache.org/proton/go/reactor".ExpiryPolicy) (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetTimeout (@"qpid.apache.org/proton/go/reactor".timeout·3 @"time".Duration) (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") SetType (@"qpid.apache.org/proton/go/reactor".type_·3 @"qpid.apache.org/proton/go/reactor".TerminusType) (? int)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Timeout () (? @"time".Duration)
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".Terminus "esc:0x0") Type () (? @"qpid.apache.org/proton/go/reactor".TerminusType)
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_session_t struct {}
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_connection_t struct {}
-	import sync "sync" // indirect
-	type @"sync".Mutex struct { @"sync".state int32; @"sync".sema uint32 }
-	func (@"sync".m·1 *@"sync".Mutex) Lock ()
-	func (@"sync".m·1 *@"sync".Mutex) Unlock ()
-	type @"qpid.apache.org/proton/go/internal".FirstError struct { @"qpid.apache.org/proton/go/internal".err error; @"qpid.apache.org/proton/go/internal".lock @"sync".Mutex }
-	func (@"qpid.apache.org/proton/go/internal".e·2 *@"qpid.apache.org/proton/go/internal".FirstError) Get () (? error)
-	func (@"qpid.apache.org/proton/go/internal".e·2 *@"qpid.apache.org/proton/go/internal".FirstError) Set (@"qpid.apache.org/proton/go/internal".err·3 error) (? error)
-	type @"net".Addr interface { Network() (? string); String() (? string) }
-	type @"net".Conn interface { Close() (? error); LocalAddr() (? @"net".Addr); Read(@"net".b []byte) (@"net".n int, @"net".err error); RemoteAddr() (? @"net".Addr); SetDeadline(@"net".t @"time".Time) (? error); SetReadDeadline(@"net".t @"time".Time) (? error); SetWriteDeadline(@"net".t @"time".Time) (? error); Write(@"net".b []byte) (@"net".n int, @"net".err error) }
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_transport_t struct {}
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_collector_t struct {}
-	type @"qpid.apache.org/proton/go/reactor".bufferChan struct { @"qpid.apache.org/proton/go/reactor".buffers chan []byte; @"qpid.apache.org/proton/go/reactor".buf1 []byte; @"qpid.apache.org/proton/go/reactor".buf2 []byte }
-	func (@"qpid.apache.org/proton/go/reactor".b·2 *@"qpid.apache.org/proton/go/reactor".bufferChan) @"qpid.apache.org/proton/go/reactor".buffer () (? []byte) { @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1, @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf2 = @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf2, @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1; return @"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1[:cap(@"qpid.apache.org/proton/go/reactor".b·2.@"qpid.apache.org/proton/go/reactor".buf1)] }
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_event_t struct {}
-	type @"qpid.apache.org/proton/go/reactor".EventType int
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".EventType) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".Event struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_event_t; @"qpid.apache.org/proton/go/reactor".eventType @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".connection @"qpid.apache.org/proton/go/reactor".Connection; @"qpid.apache.org/proton/go/reactor".session @"qpid.apache.org/proton/go/reactor".Session; @"qpid.apache.org/proton/go/reactor".link @"qpid.apache.org/proton/go/reactor".Link; @"qpid.apache.org/proton/go/reactor".delivery @"qpid.apache.org/proton/go/reactor".Delivery }
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Connection () (? @"qpid.apache.org/proton/go/reactor".Connection) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".connection }
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Delivery () (? @"qpid.apache.org/proton/go/reactor".Delivery) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".delivery }
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".eventType == @"qpid.apache.org/proton/go/reactor".EventType(0x0) }
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Link () (? @"qpid.apache.org/proton/go/reactor".Link) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".link }
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x2") Session () (? @"qpid.apache.org/proton/go/reactor".Session) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".session }
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x0") String () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".e·2 @"qpid.apache.org/proton/go/reactor".Event "esc:0x0") Type () (? @"qpid.apache.org/proton/go/reactor".EventType) { return @"qpid.apache.org/proton/go/reactor".e·2.@"qpid.apache.org/proton/go/reactor".eventType }
-	type @"qpid.apache.org/proton/go/reactor".EventHandler interface { HandleEvent(@"qpid.apache.org/proton/go/reactor".e @"qpid.apache.org/proton/go/reactor".Event) (? error) }
-	type @"sync".Once struct { @"sync".m @"sync".Mutex; @"sync".done uint32 }
-	func (@"sync".o·1 *@"sync".Once) Do (@"sync".f·2 func() "esc:0x0")
-	type @"qpid.apache.org/proton/go/reactor".Pump struct { @"qpid.apache.org/proton/go/reactor".err @"qpid.apache.org/proton/go/internal".FirstError; @"qpid.apache.org/proton/go/reactor".inject chan func(); @"qpid.apache.org/proton/go/reactor".conn @"net".Conn; @"qpid.apache.org/proton/go/reactor".connection @"qpid.apache.org/proton/go/reactor".Connection; @"qpid.apache.org/proton/go/reactor".transport *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_transport_t; @"qpid.apache.org/proton/go/reactor".collector *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_collector_t; @"qpid.apache.org/proton/go/reactor".read *@"qpid.apache.org/proton/go/reactor".bufferChan; @"qpid.apache.org/proton/go/reactor".write *@"qpid.apache.org/proton/go/reactor".bufferChan; @"qpid.apache.org/proton/go/reactor".handlers []@"qpid.apache.org/proton/go/reactor".EventHandler; @"qpid.apache.org/proton/go/reactor".running chan struct {}; @"qpid.apache.org/proton/go/reactor".closeOnce @"sync".Once }
-	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump) Close (@"qpid.apache.org/proton/go/reactor".err·2 error)
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x1") Connection () (? @"qpid.apache.org/proton/go/reactor".Connection) { return @"qpid.apache.org/proton/go/reactor".p·2.@"qpid.apache.org/proton/go/reactor".connection }
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) Error () (? error)
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) Id () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) Inject (@"qpid.apache.org/proton/go/reactor".f·3 func()) (? error)
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) InjectWait (@"qpid.apache.org/proton/go/reactor".f·3 func()) (@"qpid.apache.org/proton/go/reactor".err·1 error)
-	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump) Run ()
-	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") Server ()
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump) String () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".handle (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (? error)
-	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".pop (@"qpid.apache.org/proton/go/reactor".buf·2 *[]byte)
-	func (@"qpid.apache.org/proton/go/reactor".p·2 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".process () (? error)
-	func (@"qpid.apache.org/proton/go/reactor".p·1 *@"qpid.apache.org/proton/go/reactor".Pump "esc:0x0") @"qpid.apache.org/proton/go/reactor".push (@"qpid.apache.org/proton/go/reactor".buf·2 []byte "esc:0x0")
-	type @"qpid.apache.org/proton/go/reactor".Connection struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_connection_t }
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Close ()
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Container () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") DesiredCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Error () (? error)
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Free ()
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Hostname () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".c·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") LinkHead (@"qpid.apache.org/proton/go/reactor".s·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Link)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Links (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (@"qpid.apache.org/proton/go/reactor".links·1 []@"qpid.apache.org/proton/go/reactor".Link)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") OfferedCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Open ()
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Properties () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Pump () (? *@"qpid.apache.org/proton/go/reactor".Pump)
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Release ()
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteCondition () (? @"qpid.apache.org/proton/go/reactor".Condition)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteContainer () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteDesiredCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteHostname () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteOfferedCapabilities () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") RemoteProperties () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Reset ()
-	func (@"qpid.apache.org/proton/go/reactor".c·3 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Session () (? @"qpid.apache.org/proton/go/reactor".Session, ? error)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SessionHead (@"qpid.apache.org/proton/go/reactor".s·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Session)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") Sessions (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (@"qpid.apache.org/proton/go/reactor".sessions·1 []@"qpid.apache.org/proton/go/reactor".Session)
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetContainer (@"qpid.apache.org/proton/go/reactor".container·2 string "esc:0x0")
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetHostname (@"qpid.apache.org/proton/go/reactor".hostname·2 string "esc:0x0")
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetPassword (@"qpid.apache.org/proton/go/reactor".password·2 string "esc:0x0")
-	func (@"qpid.apache.org/proton/go/reactor".c·1 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") SetUser (@"qpid.apache.org/proton/go/reactor".user·2 string "esc:0x0")
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") State () (? @"qpid.apache.org/proton/go/reactor".State)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") String () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".c·2 @"qpid.apache.org/proton/go/reactor".Connection "esc:0x0") User () (? string)
-	type @"qpid.apache.org/proton/go/reactor".Session struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_session_t }
-	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Close ()
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Connection () (? @"qpid.apache.org/proton/go/reactor".Connection)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Error () (? error)
-	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Free ()
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") IncomingBytes () (? uint)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") IncomingCapacity () (? uint)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".s·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Next (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Session)
-	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Open ()
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") OutgoingBytes () (? uint)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") OutgoingWindow () (? uint)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Receiver (@"qpid.apache.org/proton/go/reactor".name·3 string "esc:0x0") (? @"qpid.apache.org/proton/go/reactor".Link)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") RemoteCondition () (? @"qpid.apache.org/proton/go/reactor".Condition)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") Sender (@"qpid.apache.org/proton/go/reactor".name·3 string "esc:0x0") (? @"qpid.apache.org/proton/go/reactor".Link)
-	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") SetIncomingCapacity (@"qpid.apache.org/proton/go/reactor".capacity·2 uint)
-	func (@"qpid.apache.org/proton/go/reactor".s·1 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") SetOutgoingWindow (@"qpid.apache.org/proton/go/reactor".window·2 uint)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session "esc:0x0") State () (? @"qpid.apache.org/proton/go/reactor".State)
-	func (@"qpid.apache.org/proton/go/reactor".s·2 @"qpid.apache.org/proton/go/reactor".Session) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".Link struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_link_t }
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Advance () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Available () (? int)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Close ()
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Credit () (? int)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Current () (? @"qpid.apache.org/proton/go/reactor".Delivery)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Delivery (@"qpid.apache.org/proton/go/reactor".tag·3 string "esc:0x0") (? @"qpid.apache.org/proton/go/reactor".Delivery)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Detach ()
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Drain (@"qpid.apache.org/proton/go/reactor".credit·2 int)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Drained () (? int)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Draining () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Error () (? error)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Flow (@"qpid.apache.org/proton/go/reactor".credit·2 int)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Free ()
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsDrain () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".l·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsReceiver () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") IsSender () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Name () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Next (@"qpid.apache.org/proton/go/reactor".state·3 @"qpid.apache.org/proton/go/reactor".State) (? @"qpid.apache.org/proton/go/reactor".Link)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Offered (@"qpid.apache.org/proton/go/reactor".credit·2 int)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Open ()
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Queued () (? int)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RcvSettleMode () (? @"qpid.apache.org/proton/go/reactor".RcvSettleMode)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Recv (@"qpid.apache.org/proton/go/reactor".buf·3 []byte "esc:0x0") (? int)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteCondition () (? @"qpid.apache.org/proton/go/reactor".Condition)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteCredit () (? int)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteRcvSettleMode () (? @"qpid.apache.org/proton/go/reactor".RcvSettleMode)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteSndSettleMode () (? @"qpid.apache.org/proton/go/reactor".SndSettleMode)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteSource () (? @"qpid.apache.org/proton/go/reactor".Terminus)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") RemoteTarget () (? @"qpid.apache.org/proton/go/reactor".Terminus)
-	func (@"qpid.apache.org/proton/go/reactor".link·3 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Send (@"qpid.apache.org/proton/go/reactor".m·4 @"qpid.apache.org/proton/go/amqp".Message) (? @"qpid.apache.org/proton/go/reactor".Delivery, ? error)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SendBytes (@"qpid.apache.org/proton/go/reactor".bytes·3 []byte "esc:0x0") (? int)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Session () (? @"qpid.apache.org/proton/go/reactor".Session)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SetDrain (@"qpid.apache.org/proton/go/reactor".drain·2 bool)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SetRcvSettleMode (@"qpid.apache.org/proton/go/reactor".mode·2 @"qpid.apache.org/proton/go/reactor".RcvSettleMode)
-	func (@"qpid.apache.org/proton/go/reactor".l·1 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SetSndSettleMode (@"qpid.apache.org/proton/go/reactor".mode·2 @"qpid.apache.org/proton/go/reactor".SndSettleMode)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") SndSettleMode () (? @"qpid.apache.org/proton/go/reactor".SndSettleMode)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Source () (? @"qpid.apache.org/proton/go/reactor".Terminus)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") State () (? @"qpid.apache.org/proton/go/reactor".State)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") String () (? string)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Target () (? @"qpid.apache.org/proton/go/reactor".Terminus)
-	func (@"qpid.apache.org/proton/go/reactor".l·2 @"qpid.apache.org/proton/go/reactor".Link "esc:0x0") Unsettled () (? int)
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_disposition_t struct {}
-	type @"qpid.apache.org/proton/go/reactor".Disposition struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_disposition_t }
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Annotations () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Condition () (? @"qpid.apache.org/proton/go/reactor".Condition)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Data () (? @"qpid.apache.org/proton/go/reactor".Data)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") IsFailed () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".d·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") IsUndeliverable () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SectionNumber () (? uint16)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SectionOffset () (? uint64)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetFailed (@"qpid.apache.org/proton/go/reactor".failed·2 bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetSectionNumber (@"qpid.apache.org/proton/go/reactor".section_number·2 uint16)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetSectionOffset (@"qpid.apache.org/proton/go/reactor".section_offset·2 uint64)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") SetUndeliverable (@"qpid.apache.org/proton/go/reactor".undeliverable·2 bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Disposition "esc:0x0") Type () (? uint64)
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_size_t uint64
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_char int8
-	type @"qpid.apache.org/proton/go/reactor"._Ctype_struct___0 struct { @"qpid.apache.org/proton/go/reactor".size @"qpid.apache.org/proton/go/reactor"._Ctype_size_t; @"qpid.apache.org/proton/go/reactor".start *@"qpid.apache.org/proton/go/reactor"._Ctype_char }
-	type @"qpid.apache.org/proton/go/reactor".DeliveryTag struct { @"qpid.apache.org/proton/go/reactor".pn @"qpid.apache.org/proton/go/reactor"._Ctype_struct___0 }
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".DeliveryTag) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".Delivery struct { @"qpid.apache.org/proton/go/reactor".pn *@"qpid.apache.org/proton/go/reactor"._Ctype_struct_pn_delivery_t }
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Accept ()
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Buffered () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Clear ()
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Current () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Dump ()
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") HasMessage () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") IsNil () (? bool) { return @"qpid.apache.org/proton/go/reactor".d·2.@"qpid.apache.org/proton/go/reactor".pn == nil }
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Link () (? @"qpid.apache.org/proton/go/reactor".Link)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Local () (? @"qpid.apache.org/proton/go/reactor".Disposition)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") LocalState () (? uint64)
-	func (@"qpid.apache.org/proton/go/reactor".delivery·3 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Message () (@"qpid.apache.org/proton/go/reactor".m·1 @"qpid.apache.org/proton/go/amqp".Message, @"qpid.apache.org/proton/go/reactor".err·2 error)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Partial () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Pending () (? uint)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Readable () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Reject ()
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Release (@"qpid.apache.org/proton/go/reactor".delivered·2 bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Remote () (? @"qpid.apache.org/proton/go/reactor".Disposition)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") RemoteState () (? uint64)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Settle ()
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") SettleAs (@"qpid.apache.org/proton/go/reactor".disposition·2 uint64)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Settled () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Tag () (? @"qpid.apache.org/proton/go/reactor".DeliveryTag)
-	func (@"qpid.apache.org/proton/go/reactor".d·1 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Update (@"qpid.apache.org/proton/go/reactor".state·2 uint64)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Updated () (? bool)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0") Writable () (? bool)
-	type @"".Disposition uint64
-	func (@"".d·2 @"".Disposition) String () (? string)
-	type @"".ReceivedMessage struct { Message @"qpid.apache.org/proton/go/amqp".Message; @"".eDelivery @"qpid.apache.org/proton/go/reactor".Delivery; @"".receiver @"".Receiver }
-	func (@"".rm·2 *@"".ReceivedMessage) Accept () (? error)
-	func (@"".rm·2 *@"".ReceivedMessage) Acknowledge (@"".disposition·3 @"".Disposition) (@"".err·1 error)
-	func (@"".rm·2 *@"".ReceivedMessage) Reject () (? error)
-	type @"".Receiver interface { AddCredit(@"".n int); Buffer() (? chan<- @"".ReceivedMessage); Close(? error); Credit() (@"".len int, @"".credit int, @"".max int); Error() (? error); IsOpen() (? bool); IsReceiver() (? bool); IsSender() (? bool); Name() (? string); Open() (? error); Receive() (? @"".ReceivedMessage, ? error); SetCapacity(@"".capacity int, @"".prefetch bool); SetName(? string); SetSource(? string); SetTarget(? string); Source() (? string); String() (? string); Target() (? string) }
-	type @"".errorHolder struct { @"".err @"qpid.apache.org/proton/go/internal".FirstError }
-	func (@"".e·2 *@"".errorHolder) Error () (? error)
-	func (@"".e·2 *@"".errorHolder) @"".setError (@"".err·3 error) (? error)
-	type @"".endpoint struct { ? @"".errorHolder; @"".str string }
-	func (@"".e·2 *@"".endpoint "esc:0x1") String () (? string) { return @"".e·2.@"".str }
-	type @"qpid.apache.org/proton/go/reactor".MessagingEventType int
-	func (@"qpid.apache.org/proton/go/reactor".t·2 @"qpid.apache.org/proton/go/reactor".MessagingEventType) String () (? string)
-	type @"qpid.apache.org/proton/go/reactor".MessagingHandler interface { HandleMessagingEvent(? @"qpid.apache.org/proton/go/reactor".MessagingEventType, ? @"qpid.apache.org/proton/go/reactor".Event) (? error) }
-	type @"qpid.apache.org/proton/go/reactor".Endpoint interface { Close(); Condition() (? @"qpid.apache.org/proton/go/reactor".Condition); Open(); RemoteCondition() (? @"qpid.apache.org/proton/go/reactor".Condition); State() (? @"qpid.apache.org/proton/go/reactor".State); String() (? string) }
-	type @"qpid.apache.org/proton/go/reactor".endpointDelegator struct { @"qpid.apache.org/proton/go/reactor".remoteOpen @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".remoteClose @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".localOpen @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".localClose @"qpid.apache.org/proton/go/reactor".EventType; @"qpid.apache.org/proton/go/reactor".opening @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".opened @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".closing @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".closed @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".error @"qpid.apache.org/proton/go/reactor".MessagingEventType; @"qpid.apache.org/proton/go/reactor".
 endpoint func(? @"qpid.apache.org/proton/go/reactor".Event) (? @"qpid.apache.org/proton/go/reactor".Endpoint); @"qpid.apache.org/proton/go/reactor".delegate @"qpid.apache.org/proton/go/reactor".MessagingHandler }
-	func (@"qpid.apache.org/proton/go/reactor".d·2 @"qpid.apache.org/proton/go/reactor".endpointDelegator) HandleEvent (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (@"qpid.apache.org/proton/go/reactor".err·1 error)
-	type @"qpid.apache.org/proton/go/reactor".MessagingDelegator struct { @"qpid.apache.org/proton/go/reactor".delegate @"qpid.apache.org/proton/go/reactor".MessagingHandler; @"qpid.apache.org/proton/go/reactor".connection @"qpid.apache.org/proton/go/reactor".endpointDelegator; @"qpid.apache.org/proton/go/reactor".session @"qpid.apache.org/proton/go/reactor".endpointDelegator; @"qpid.apache.org/proton/go/reactor".link @"qpid.apache.org/proton/go/reactor".endpointDelegator; @"qpid.apache.org/proton/go/reactor".handshaker @"qpid.apache.org/proton/go/reactor".EventHandler; @"qpid.apache.org/proton/go/reactor".flowcontroller @"qpid.apache.org/proton/go/reactor".EventHandler; AutoSettle bool; AutoAccept bool; Prefetch int; PeerCloseError bool }
-	func (@"qpid.apache.org/proton/go/reactor".d·2 *@"qpid.apache.org/proton/go/reactor".MessagingDelegator) HandleEvent (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (? error)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 *@"qpid.apache.org/proton/go/reactor".MessagingDelegator) @"qpid.apache.org/proton/go/reactor".incoming (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (@"qpid.apache.org/proton/go/reactor".err·1 error)
-	func (@"qpid.apache.org/proton/go/reactor".d·2 *@"qpid.apache.org/proton/go/reactor".MessagingDelegator) @"qpid.apache.org/proton/go/reactor".outgoing (@"qpid.apache.org/proton/go/reactor".e·3 @"qpid.apache.org/proton/go/reactor".Event) (@"qpid.apache.org/proton/go/reactor".err·1 error)
-	type @"".sender struct { ? @"".link; @"".deliveries map[@"qpid.apache.org/proton/go/reactor".Delivery]*@"".SentMessage }
-	func (@"".s·1 *@"".sender) Close (@"".err·2 error)
-	func (@"".s·2 *@"".sender) Open () (@"".err·1 error)
-	func (@"".s·3 *@"".sender) Send (@"".m·4 @"qpid.apache.org/proton/go/amqp".Message) (@"".sm·1 *@"".SentMessage, @"".err·2 error)
-	func (@"".s·1 *@"".sender) @"".close (@"".err·2 error)
-	func (@"".s·1 *@"".sender "esc:0x0") @"".handleDelivery (@"".delivery·2 @"qpid.apache.org/proton/go/reactor".Delivery "esc:0x0")
-	type @"".SentMessage struct { @"".sender *@"".sender; @"".eDelivery @"qpid.apache.org/proton/go/reactor".Delivery; @"".done chan struct {}; @"".disposition @"".Disposition }
-	func (@"".sm·3 *@"".SentMessage) Wait () (? @"".Disposition, ? error)
-	func (@"".sm·3 *@"".SentMessage) WaitTimeout (@"".timeout·4 @"time".Duration) (? @"".Disposition, ? error)
-	type @"".Sender interface { Close(? error); Error() (? error); IsOpen() (? bool); IsReceiver() (? bool); IsSender() (? bool); Name() (? string); Open() (? error); Send(@"".m @"qpid.apache.org/proton/go/amqp".Message) (@"".sm *@"".SentMessage, @"".err error); SetName(? string); SetSource(? string); SetTarget(? string); Source() (? string); String() (? string); Target() (? string) }
-	type @"".session struct { ? @"".endpoint; @"".eSession @"qpid.apache.org/proton/go/reactor".Session; @"".connection *@"".Connection }
-	func (@"".s·1 *@"".session) Close (@"".err·2 error)
-	func (@"".s·2 *@"".session "esc:0x1") Connection () (? *@"".Connection) { return @"".s·2.@"".connection }
-	func (@"".s·2 *@"".session) NewReceiver (@"".target·3 string) (@"".rcv·1 @"".Receiver)
-	func (@"".s·2 *@"".session) NewSender (@"".target·3 string) (@"".snd·1 @"".Sender)
-	func (@"".s·2 *@"".session) Open () (? error)
-	func (@"".s·2 *@"".session "esc:0x1") @"".eEndpoint () (? @"qpid.apache.org/proton/go/reactor".Endpoint) { return @"".s·2.@"".eSession }
-	func (@"".s·2 *@"".session "esc:0x1") @"".pump () (? *@"qpid.apache.org/proton/go/reactor".Pump) { return @"".s·2.@"".connection.@"".pump }
-	type @"".link struct { ? @"".endpoint; @"".session *@"".session; @"".isSender bool; @"".eLink @"qpid.apache.org/proton/go/reactor".Link; @"".name string; @"".source string; @"".target string; @"".isOpen bool }
-	func (@"".l·2 *@"".link "esc:0x1") Connection () (? *@"".Connection)
-	func (@"".l·2 *@"".link "esc:0x0") IsOpen () (? bool) { return @"".l·2.@"".isOpen }
-	func (@"".l·2 *@"".link "esc:0x0") IsReceiver () (? bool) { return !@"".l·2.@"".isSender }
-	func (@"".l·2 *@"".link "esc:0x0") IsSender () (? bool) { return @"".l·2.@"".isSender }
-	func (@"".l·2 *@"".link "esc:0x1") Name () (? string) { return @"".l·2.@"".name }
-	func (@"".l·2 *@"".link "esc:0x1") Session () (? @"".Session) { return @"".l·2.@"".session }
-	func (@"".l·1 *@"".link) SetName (@"".s·2 string)
-	func (@"".l·1 *@"".link) SetSource (@"".s·2 string)
-	func (@"".l·1 *@"".link) SetTarget (@"".s·2 string)
-	func (@"".l·2 *@"".link "esc:0x1") Source () (? string) { return @"".l·2.@"".source }
-	func (@"".l·2 *@"".link "esc:0x1") Target () (? string) { return @"".l·2.@"".target }
-	func (@"".l·1 *@"".link) @"".close (@"".err·2 error)
-	func (@"".l·2 *@"".link "esc:0x0") @"".handler () (? *@"".handler)
-	func (@"".l·2 *@"".link) @"".localSetup () (? error)
-	func (@"".l·2 *@"".link) @"".open () (? error)
-	func (@"".l·2 *@"".link "esc:0x0") @"".pump () (? *@"qpid.apache.org/proton/go/reactor".Pump)
-	func (@"".l·1 *@"".link) @"".setPanicIfLink ()
-	func (@"".l·1 *@"".link) @"".setPanicIfOpen ()
-	func (@"".l·1 *@"".link) @"".setString ()
-	type @"".policy interface { Post(? *@"".receiver, ? error); Pre(? *@"".receiver) }
-	type @"".receiver struct { ? @"".link; @"".capacity int; @"".prefetch bool; @"".buffer chan @"".ReceivedMessage; @"".policy @"".policy }
-	func (@"".r·1 *@"".receiver) AddCredit (@"".n·2 int)
-	func (@"".r·2 *@"".receiver "esc:0x1") Buffer () (? chan<- @"".ReceivedMessage) { return @"".r·2.@"".buffer }
-	func (@"".r·2 *@"".receiver "esc:0x0") Capacity () (? int) { return cap(@"".r·2.@"".buffer) }
-	func (@"".r·1 *@"".receiver) Close (@"".err·2 error)
-	func (@"".r·4 *@"".receiver) Credit () (@"".buffered·1 int, @"".credit·2 int, @"".capacity·3 int)
-	func (@"".r·2 *@"".receiver) Open () (@"".err·1 error)
-	func (@"".r·3 *@"".receiver) Receive () (@"".rm·1 @"".ReceivedMessage, @"".err·2 error)
-	func (@"".r·1 *@"".receiver) SetCapacity (@"".capacity·2 int, @"".prefetch·3 bool)
-	func (@"".r·1 *@"".receiver) @"".close (@"".err·2 error)
-	func (@"".r·4 *@"".receiver "esc:0x0") @"".credit () (@"".buffered·1 int, @"".credit·2 int, @"".capacity·3 int)
-	func (@"".r·1 *@"".receiver) @"".handleDelivery (@"".delivery·2 @"qpid.apache.org/proton/go/reactor".Delivery)
-	type @"".handler struct { @"".delegator *@"qpid.apache.org/proton/go/reactor".MessagingDelegator; @"".connection *@"".Connection; @"".receivers map[@"qpid.apache.org/proton/go/reactor".Link]*@"".receiver; @"".senders map[@"qpid.apache.org/proton/go/reactor".Link]*@"".sender; @"".sessions map[@"qpid.apache.org/proton/go/reactor".Session]*@"".session }
-	func (@"".h·2 *@"".handler) HandleMessagingEvent (@"".t·3 @"qpid.apache.org/proton/go/reactor".MessagingEventType, @"".e·4 @"qpid.apache.org/proton/go/reactor".Event) (? error)
-	func (@"".h·1 *@"".handler "esc:0x0") @"".close ()
-	type @"qpid.apache.org/proton/go/amqp".UidCounter struct { @"qpid.apache.org/proton/go/amqp".count uint64 }
-	func (@"qpid.apache.org/proton/go/amqp".uc·2 *@"qpid.apache.org/proton/go/amqp".UidCounter) Next () (? string)
-	func (@"qpid.apache.org/proton/go/amqp".uc·2 *@"qpid.apache.org/proton/go/amqp".UidCounter) NextInt () (? uint64)
-	type @"qpid.apache.org/proton/go/internal".FlexChannel struct { In chan<- interface {}; Out <-chan interface {}; @"qpid.apache.org/proton/go/internal".in chan interface {}; @"qpid.apache.org/proton/go/internal".out chan interface {}; @"qpid.apache.org/proton/go/internal".buffer []interface {}; @"qpid.apache.org/proton/go/internal".limit int }
-	func (@"qpid.apache.org/proton/go/internal".fc·1 *@"qpid.apache.org/proton/go/internal".FlexChannel) @"qpid.apache.org/proton/go/internal".run ()
-	type @"net".Listener interface { Accept() (@"net".c @"net".Conn, @"net".err error); Addr() (? @"net".Addr); Close() (? error) }
-	type @"".Connection struct { Server bool; AllowIncoming int; LinkPrefix string; ? @"".endpoint; @"".handler *@"".handler; @"".pump *@"qpid.apache.org/proton/go/reactor".Pump; @"".err @"qpid.apache.org/proton/go/internal".FirstError; @"".linkNames @"qpid.apache.org/proton/go/amqp".UidCounter; @"".eConnection @"qpid.apache.org/proton/go/reactor".Connection; @"".incoming *@"qpid.apache.org/proton/go/internal".FlexChannel }
-	func (@"".c·2 *@"".Connection) Accept (@"".l·3 @"net".Listener) (? error)
-	func (@"".c·1 *@"".Connection) Close (@"".err·2 error)
-	func (@"".c·2 *@"".Connection) Dial (@"".network·3 string, @"".address·4 string) (? error)
-	func (@"".c·3 *@"".Connection) Incoming () (? @"".Endpoint, ? error)
-	func (@"".c·3 *@"".Connection) IncomingTimeout (@"".timeout·4 @"time".Duration) (? @"".Endpoint, ? error)
-	func (@"".c·2 *@"".Connection) Open (@"".conn·3 @"net".Conn) (@"".err·1 error)
-	func (@"".c·3 *@"".Connection) OpenSession () (@"".s·1 @"".Session, @"".err·2 error)
-	func (@"".c·1 *@"".Connection) @"".close (@"".err·2 error)
-	func (@"".c·1 *@"".Connection "esc:0x0") @"".handleIncoming (@"".sn·2 *@"".session, @"".l·3 @"qpid.apache.org/proton/go/reactor".Link)
-	func (@"".c·2 *@"".Connection) @"".nextLinkName () (? string)
-	type @"".Session interface { Close(? error); Connection() (? *@"".Connection); Error() (? error); NewReceiver(@"".target string) (? @"".Receiver); NewSender(@"".target string) (? @"".Sender); Open() (? error); String() (? string) }
-	type @"qpid.apache.org/proton/go/internal".Error string
-	func (@"qpid.apache.org/proton/go/internal".e·2 @"qpid.apache.org/proton/go/internal".Error "esc:0x0") Error () (? string) { return "proton: " + string(@"qpid.apache.org/proton/go/internal".e·2) }
-	var @"".Timeout @"qpid.apache.org/proton/go/internal".Error
-	const @"".Forever @"time".Duration = -0x1
-	const @"".Unlimited = -0x1
-	const @"".NoDisposition @"".Disposition = 0x0
-	const @"".Accepted = 0x24
-	const @"".Rejected = 0x25
-	const @"".Released = 0x26
-	func @"".init ()
-	var @"time".months [12]string
-	var @"time".days [7]string
-	var @"time".Local *@"time".Location
-	var @"time".UTC *@"time".Location
-
-$$
-_go_.6          0           0     0     644     468572    `
-go object linux amd64 go1.4.2 X:precisestack
-
-!
-go13ld
@qpid.apache.org/proton/go/amqp.aFqpid.apache.org/proton/go/reactor.a
-fmt.aio.aHqpid.apache.org/proton/go/internal.areflect.atime.aruntime/cgo.asyscall.a
-net.a�"".newHandler�	�	dH�%H;aw���H��XH�H�$H�D$�H�\$H�\$@H�H�$H�D$�H�\$H�\$8H�H�$H�D$�H�\$H�\$0H�H�$�H�L$H��H����
1��H�L$(H�$H�<$�y
H�$H�\$`H�\$�H�\$(H�$H�<$�E
H�$H�\$@H�\$�H�\$(H�$H�<$�
H�$H�\$8H�\$�H�\$(H�$H�<$��H�$ H�\$0H�\$�H�D$(H�D$ H�D$(H�1�H9�tzH�L$(H�D$HH�$H�L$PH�L$�H�D$H�\$ H�$H�<$t?H�D$�H�D$ H�HǃX
H�1�@��Q
H�1�@��P
H�D$hH��XÉ%�H�H�$H�H�\$H�H�\$�H�D$�T����%�����%������%�����%�{����
�Y���,
- 0runtime.morestack_noctxt:xtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver^runtime.makemap�
ttype.map[qpid.apache.org/proton/go/reactor.Link]*"".sender�
runtime.makemap�
|type.map[qpid.apache.org/proton/go/reactor.Session]*"".session�
runtime.makemap�type."".handler�"runtime.newobject�� runtime.duffzero�.runtime.writebarrierptr�.runtime.writebarrierptr�.runtime.writebarrierptr�.runtime.writebarrierptr��
go.itab.*"".handler.qpid.apache.org/proton/go/reactor.MessagingHandler�nqpid.apache.org/proton/go/reactor.NewMessagingDelegator�.runtime.writebarrierptr� type.*"".handler�ntype.qpid.apache.org/proton/go/reactor.MessagingHandler��
go.itab.*"".handler.qpid.apache.org/proton/go/reactor.MessagingHandler� runtime.typ2Itab �
"".autotmp_0033_ type.*"".handle
 r"".autotmp_0031 type.*"".handler"".autotmp_0030O|type.map[qpid.apache.org/proton/go/reactor.Session]*"".session"".autotmp_0029?ttype.map[qpid.apache.org/proton/go/reactor.Link]*"".sender"".autotmp_0028/xtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver"".ho type.*"".handler"".~r1 type.*"".handler"".c&type.*"".Connection�
��

�
v�4L##�
Y
-	;;0.##A(((:�

JTgclocals·a89e82532b08703817da6ad245f4f6c1Tgclocals·afe2b15161969548d2683e49e081ad97�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/handler.go�D"".(*handler).HandleMessagingEvent�:�:dH�%H��$ ���H;Aw���H��`H��$hHDŽ$�HDŽ$�H��$pH���>H���tH���
H��$xH��$@H��H���H��$XH��$�H�$��\$H��
H!À���1�<�.
H��$xH��$�H��H���H��$�H��$hH�kH�,$H�D$hH�D$�H�T$H��$xH��$ H��H���H��$8H��$�H��$�H��$�H��$�H�H�$H��$hH�k H�l$H��$�H�\$H��$�H�\$�H��$hH�iH���1�H9�toH��$�H��$@
H�H��$8
H�H�$H�YH��
 ��H�+H�l$H��$8
H�\$�HDŽ$�HDŽ$�H��`�H��$xH��$H��H���H��$H��$�H��$�H�H�$H�5H�t$H�5H�l$H��H�H�H�\$ H�H�CH�C�H�\$8H��$p
H��H���H�H�$H�H�\$H�H�\$H��$�H�\$�H�\$ H��$
H�\$(H��$ 
H�H�$H�H�\$H�H�\$H��$p
H�\$�H�\$ H�l$H��H��H�H�H��$
H�$H��$ 
H�\$�����H��
�M���H���y���H��$xH��$H��H���H��$0H��$�H��$�H�$�H��$��\$H��
H!À���1�<����H��$hH�mH���1�H9��&
H��$
H�H�$H�5H�t$H�5H�l$H��H�H�H�\$ H�H�CH�C�H�\$8H��$p
H�
 �H���H�H�$H�H�\$H�H�\$H��$
H�\$�H�\$ H��$
H�\$(H��$ 
H�H�$H�H�\$H�H�\$H��$p
H�\$�H�\$ H�l$H��H��H�H�H��$
H�$H��$ 
H�\$������H�4$�H�\$H��$�H�H�$H��$hH�k H�l$H��$�H�\$�H��$�H�\$H�1�H9��&
H��$
H�H�$H�5H�t$H�5H�l$H��H�H�H�\$ H�H�CH�C�H�\$8H��$p
H��H���H�H�$H�H�\$H�H�\$H��$
H�\$�H�\$ H��$
H�\$(H��$ 
H�H�$H�H�\$H�H�\$H��$p
H�\$�H�\$ H�l$H��H��H�H�H��$
H�$H��$ 
H�\$��J���H��$hH�kH�,$H�D$H�T$��&���H��
�����H��u^H��$xH��$�H�
 ���H���H��$�H��$�H��$�H�H�$H�j H�l$H��$�H�\$�����H�������H��$xH��$�H��H���H��$�H�D$xH��$�H�$�H�D$H��$�H�$�H�L$H�D$H��$
H��$
H��$�H��$
H�H�$H��$hH�kH�l$H��$
H�\$�H�\$H�1�H9�t#H�$H��$
H�\$H��$
H�\$�H��$�H��$
H�H�$H��$hH�kH�l$H��$
H�\$�H�\$H�1�H9������H�$H��$
H�\$H��$
H�\$��Z���H���{H���
H��$xH��$pH��H���H��$�H��$�H��$
H�H�$H�jH�l$H��$
H�\$�H�\$H�1�H9�tH�$H�\$H�H�C�H��$xH��$0H��H���H��$PH��$�H��$
H�
 ��H�$H��$hH�kH�l$H��$
H�\$�H�\$H�1�H9��M���H�$H�\$H�H�C��+���H���!���H��$xH��$�
H��H���H��$�
H�D$pH��$
H�H�$H�jH�l$H��$
H�\$�H�\$H�1�H9�t;H��$xH��$PH��H���H��$xH�$H�L$`H�L$�����H��$xH��$�
H��H���H��$H��$�H��$
H��$H
H�H�CH��$H
H���I
H��
H��
H��$X
H��$`
H��$h
H�H�$H��$
H�\$�H�T$H�D$H��$X
H�$H��$(
H�T$H��$0
H�D$�H�H�$H�5H�t$H�5H�l$H��H�H�H��$X
H�\$ H��$`
H�\$(H��$h
H�\$0�H�\$8H��$p
H��H���H�H�$H�H�\$H�H�\$H��$p
H�\$�H�\$ H�l
 $H��H��H�H�H��$hH�kH�,$�����������H���OH��$xH��$�H��H���H��$H��$�H��$
H�H�$H�jH�l$H��$
H�\$�H�\$H�1�H9�t>H��$xH��$�H��H���H��$�H�$H��$�H�L$��%���H��$xH��$�
H��H���H��$�
H�D$XH��$
H��$H
H�H�CH��$H
H���I
H��
H��
H��$X
H��$`
H��$h
H�H�$H��$
H�\$�H�T$H�D$H��$X
H�$H��$(
H�T$H��$0
H�D$�H�H�$H�5H�t$H�5H�l$H��H�H�H��$X
H�\$ H��$`
H�\$(H��$h
H�\$0�H�\$8H��$p
H��H���H�H�$H�H�\$H�H�\$H��$p
H�\$�H�\$ H�l$H��H��H�H�H��$hH�kH�,$���
 ���������H���r���H�$��d����

-00runtime.morestack_noctxt�� runtime.duffcopy�^qpid.apache.org/proton/go/reactor.Session.State�� runtime.duffcopy�"".newSession�� runtime.duffcopy�|type.map[qpid.apache.org/proton/go/reactor.Session]*"".session�$runtime.mapassign1� type.*"".session�0type.chan<- interface {}�"runtime.chansend1�� runtime.duffcopy�	Rqpid.apache.org/proton/go/amqp.NotAllowed�	Rqpid.apache.org/proton/go/amqp.NotAllowed�	Ngo.string."remote sessions not allowed"�
-Jqpid.apache.org/proton/go/amqp.Errorf�
-� runtime.duffcopy�
-\type.qpid.apache.org/proton/go/reactor.Session�
-^type.qpid.apache.org/proton/go/reactor.Endpoint�
-�
go.itab.qpid.apache.org/proton/go/reactor.Session.qpid.apache.org/proton/go/reactor.Endpoint�runtime.convT2I�Rtype.qpid.apache.org/proton/go/amqp.Error�type.error�dgo.itab.qpid.apache.org/proton/go/amqp.Error.error�runtime.convT2I�
Xqpid.apache.org/proton/go/reactor.CloseError�� runtime.duffcopy�Xqpid.apache.org/proton/go/reactor.Link.State�Rqpid.apache.org/proton/go/amqp.NotAllowed�Rqpid.apache.org/proton/go/amqp.NotAllowed�6go.string."no remote links"�Jqpid.apache.org/proton/go/amqp.Errorf�� runtime.duffcopy�Vtype.qpid.apache.org/proton/go/reactor.Link�^type.qpid.apache.org/proton/go/reactor.Endpoint��
go.itab.qpid.apache.org/proton/go/reactor.Link.qpid.apache.org/proton/go/reactor.Endpoint�runtime.convT2I�Rtype.qpid.apache.org/proton/go/amqp.Error�type.error�dgo.ita
 b.qpid.apache.org/proton/go/amqp.Error.error�runtime.convT2I�Xqpid.apache.org/proton/go/reactor.CloseError�\qpid.apache.org/proton/go/reactor.Link.Session�|type.map[qpid.apache.org/proton/go/reactor.Session]*"".session�$runtime.mapaccess1�Xqpid.apache.org/proton/go/amqp.InternalError�Xqpid.apache.org/proton/go/amqp.InternalError�Pgo.string."cannot find session for link"�Jqpid.apache.org/proton/go/amqp.Errorf�� runtime.duffcopy�Vtype.qpid.apache.org/proton/go/reactor.Link�^type.qpid.apache.org/proton/go/reactor.Endpoint��
go.itab.qpid.apache.org/proton/go/reactor.Link.qpid.apache.org/proton/go/reactor.Endpoint�runtime.convT2I�Rtype.qpid.apache.org/proton/go/amqp.Error�type.error�dgo.itab.qpid.apache.org/proton/go/amqp.Error.error�runtime.convT2I�Xqpid.apache.org/proton/go/reactor.CloseErro
 r�>"".(*Connection).handleIncoming�� runtime.duffcopy�|type.map[qpid.apache.org/proton/go/reactor.Session]*"".session�"runtime.mapdelete�� runtime.duffcopy�lqpid.apache.org/proton/go/reactor.Link.RemoteCondition�bqpid.apache.org/proton/go/reactor.Condition.Error�xtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver�$runtime.mapaccess1� ("".(*receiver).close� ttype.map[qpid.apache.org/proton/go/reactor.Link]*"".sender�!$runtime.mapaccess1�"$"".(*sender).close�#� runtime.duffcopy�#xtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver�#$runtime.mapaccess1�$("".(*receiver).close�%� runtime.duffcopy�%ttype.map[qpid.apache.org/proton/go/reactor.Link]*"".sender�&$runtime.mapaccess1�&$"".(*sender).close�'� runtime.duffcopy�(ttype.map[qpid.apache.org/pro
 ton/go/reactor.Link]*"".sender�($runtime.mapaccess1�)� runtime.duffcopy�)6"".(*sender).handleDelivery�*� runtime.duffcopy�+Vtype.qpid.apache.org/proton/go/reactor.Link�,runtime.convT2E�,2runtime.writebarrieriface�-Xqpid.apache.org/proton/go/amqp.InternalError�-Xqpid.apache.org/proton/go/amqp.InternalError�-Tgo.string."cannot find sender for link %s"�.Jqpid.apache.org/proton/go/amqp.Errorf�.� runtime.duffcopy�.Rtype.qpid.apache.org/proton/go/amqp.Error�.type.error�/dgo.itab.qpid.apache.org/proton/go/amqp.Error.error�/runtime.convT2I�0,"".(*Connection).close�0� runtime.duffcopy�1xtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver�1$runtime.mapaccess1�2� runtime.duffcopy�3:"".(*receiver).handleDelivery�3� runtime.duffcopy�5Vtype.qpid.apache.org/prot
 on/go/reactor.Link�5runtime.convT2E�62runtime.writebarrieriface�6Xqpid.apache.org/proton/go/amqp.InternalError�6Xqpid.apache.org/proton/go/amqp.InternalError�6Xgo.string."cannot find receiver for link %s"�7Jqpid.apache.org/proton/go/amqp.Errorf�8� runtime.duffcopy�8Rtype.qpid.apache.org/proton/go/amqp.Error�8type.error�8dgo.itab.qpid.apache.org/proton/go/amqp.Error.error�8runtime.convT2I�9,"".(*Connection).close�:&"".(*handler).close�
��
"".autotmp_0084^type.qpid.apache.org/proton/go/reactor.Endpoint"".autotmp_0083^type.qpid.apache.org/proton/go/reactor.Endpoint"".autotmp_0082type.bool"".autotmp_0081�
^type.qpid.apache.org/proton/go/reactor.Endpoint"".autotmp_0079"type.interface {}"".autotmp_0078*type.*[1]interface {}"".autotmp_0077&type.[]interface {}"".autotmp_0076�"type.interface {}"".autotmp_0074�&
 type.[]interface {}"".autotmp_0072type.*"".sender"".autotmp_0071Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0070"type.*"".receiver"".autotmp_0069Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0068type.*"".sender"".autotmp_0067Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0066"type.*"".receiver"".autotmp_0065Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0063�
`type.qpid.apache.org/proton/go/reactor.Condition"".autotmp_0062Rtype.qpid.apache.org/proton/go/amqp.Error"".autotmp_0061Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0060 type.*"".session"".autotmp_0059\type.qpid.apache.org/proton/go/reactor.Session"".autotmp_0058Rtype.qpid.apache.org/proton/go/amqp.Error"".autotmp_0057Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0056Xtype.qpid.apache.org/proton/go/reactor.State"".autotmp_0055\type.qpid.apache.org/proton/go/reactor.Session"".autotmp_0
 054Rtype.qpid.apache.org/proton/go/amqp.Error"".autotmp_0053\type.qpid.apache.org/proton/go/reactor.Session"".autotmp_0052�"type.interface {}"".autotmp_0051 type.*"".session"".autotmp_0050�
 type.*"".session"".autotmp_0049�
\type.qpid.apache.org/proton/go/reactor.Session"".autotmp_0046Rtype.qpid.apache.org/proton/go/amqp.Error"".autotmp_0045Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0044(type.[1]interface {}"".autotmp_0042Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0041�Rtype.qpid.apache.org/proton/go/amqp.Error"".autotmp_0040Vtype.qpid.apache.org/proton/go/reactor.Link"".autotmp_0039�(type.[1]interface {}"".autotmp_0037�
Vtype.qpid.apache.org/proton/go/reactor.Link"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/proton/go/reactor.e·2_Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/p
 roton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�\type.qpid.apache.org/proton/go/reactor.SessionLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�\type.qpid.apache.org/proton/go/reactor.SessionLqpid.apache.org/proton/go/reactor.e·2�
Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�\type.qpid.apache.org/proton/go/reactor.SessionLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�\type.qpid.apache.org/proton/go/reactor.SessionLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�\type
 .qpid.apache.org/proton/go/reactor.SessionLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/proton/go/reactor.e·2�	Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�^type.qpid.apache.org/proton/go/reactor.DeliveryLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/proton/go/reactor.e·2�
-Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�^type.qpid.apache.org/proton/go/reactor.DeliveryLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".~r0�Vtype.qpid.apache.org/proton/go/reactor.LinkLqpid.apache.org/proton/go/reactor.e·2�Xtype.qpid.apache.org/proton/go/reactor.Event"".err�
type.error"".l�
Vtype.qpid.apache.org/proton/go/reactor.Link"".l�Vtype.qpid.apache.org/proton/go/reactor.Link"".s� type.*"".session"".~r2�
type.error"".e Xtype.qpid.apache.org/proton/go/reactor.Event"".trtype.qpid.apache.org/proton/go/reactor.MessagingEventType"".h type.*"".handler%���
����jE&
-VG�
Ob ]�^i
-+;�HAT�>78K	YT1
-(AM#Q#$�

-z
-ht}
-e6xq�rq
-h9�
�
��
�
f
-	
-�
�
�
i�
MO2
W�
MO2
;nMO2
$pHn2>6r,
a0
eE
�
�
M�
H
�
�
MH!Tgclocals·b82cb6ebf331abc37c079649e2b6da7cTgclocals·8db54c8e460d681e679ff513c38148da�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/handler.go�&"".(*handler).close��dH�%H�D$�H;Aw���H��H��$�H�kH�|$h1��H�H�$H�l$H�\$hH�\$�H�\$h1�H9�tNH�\$pH�+H�\$hH����H�,$H�\$H�H�C�H�\$hH�$�H�\$h1�H9�u�H��$�H�kH�|$1��H�H�$H�l$H�\$H�\$�H�\$1�H9�tJH�\$ H�+H�\$H��t?H�,$H�\$H�H�C�H�\$H�$�H�\$1�H9�u�H�ĸÉ뽉�)���
-*0runtime.morestack_noctxtl� runtime.duffzerozxtype.map[qpid.apache.org/proton/go/reactor.Link]*"".receiver�
&runtime.mapiterinit�("".(*receiver).close�&runtime.mapiternext�� runtime.duffzero�ttype.map[qpid.apache.org/proton/go/reactor.Link]*"".sender�&runtime.mapiterinit�$"".(*sender).close�&runtime.mapiternext�"".autotmp_0095�~type.map.iter[qpid.apache.org/proton/go/reactor.Link]*"".sender"".autotmp_0093�
�
type.map.iter[qpid.apache.org/proton/go/reactor.Link]*"".receiver"".h type.*"".handler"���
��4�"Z
V
T�
{Tgclocals·15395a9df917b4c9aa74d5c6c7e1ebf4Tgclocals·71f80432bc6668593abff0f0dbd021b7�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/handler.go�4"".(*errorHolder).setError��
dH�%H;aw���H��(H�D$HH�D$P
 H�\$0H�$H�<$t2H�\$8H�\$H�\$@H�\$�H�L$H�D$ H�L$HH�D$PH��(É%��
- 0runtime.morestack_noctxt�
hqpid.apache.org/proton/go/internal.(*FirstError).SetPP"".~r10type.error"".errtype.error"".e(type.*"".errorHolderPSO
P�
|�

-P0Tgclocals·57e1009a600f832f844e0e3c49ba5a89Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�."".(*errorHolder).Error�
�
dH�%H;aw���H��H�D$(H�D$0H�\$ H�$H�<$t�H�L$H�D$H�L$(H�D$0H��É%��
- 0runtime.morestack_noctxtzhqpid.apache.org/proton/go/internal.(*FirstError).Get00"".~r0type.error"".e(type.*"".errorHolder0?/
0p~p
-<4Tgclocals·a08e9001cb8f9d822225de3b8e406515Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�*"".(*endpoint).String`DH�\$H��tH�kH�l$H�k H�l$��0"".~r0type.string"".e"type.*"".endpoint00�
0Tgclocals·a08e9001cb8f9d822225de3b8e406515Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�2"".(*link).setPanicIfOpen��dH�%H;aw���H��H��$��ip@����H��H�\$XH�H�CH�\$XH����H��
H��
H�T$pH�L$xH�\$hH�$H�H�D$8H�D$H�l$@H�l$�H�H�,$H��H��H�H�H�\$hH�\$H�\$pH�\$H�\$xH�\$ �H�\$(H�\$HH�\$0H�\$PH�H�$H�\$HH�\$�H�\$H�,$H��H��H�H��
 ��8���H�Ā�
- 0runtime.morestack_noctxt�
type.*"".link�2runtime.writebarrieriface�^go.string."cannot set property on open link %s"�Rqpid.apache.org/proton/go/internal.Errorf�Ztype.qpid.apache.org/proton/go/internal.Error�runtime.convT2E�runtime.gopanic�"".autotmp_0103/&type.[]interface {}"".autotmp_0102oZtype.qpid.apache.org/proton/go/internal.Error"".autotmp_0100O(type.[1]interface {}"".ltype.*"".link���
��%�
�
8.5Tgclocals·fbd5b7009fdd3864023723132632a4f4Tgclocals·2276d8371a4f8737752113708e64c2a5�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�2"".(*link).setPanicIfLink��dH�%H�D$�H;Aw���H��H��$�H�$�H��$�H���&
H�Y8H�\$81�H9��
1�<��H��H�\$`H�H�CH�\$`H����H
 ��
H��
H�T$xH��$�H�\$pH�$H�H�D$@H�D$H�l$HH�l$�H�H�,$H��H��H�H�H�\$pH�\$H�\$xH�\$H��$�H�\$ �H�\$(H�\$PH�\$0H�\$XH�H�$H�\$PH�\$�H�\$H�,$H��H��H�H����2���H�Ĉ�H��
������
�����
-*0runtime.morestack_noctxt^2"".(*link).setPanicIfOpen�type.*"".link�2runtime.writebarrieriface�xgo.string."cannot set set link property on incoming link %s"�Rqpid.apache.org/proton/go/internal.Errorf�Ztype.qpid.apache.org/proton/go/internal.Error�runtime.convT2E�runtime.gopanic�
-"".autotmp_0114/&type.[]interface {}"".autotmp_0112oZtype.qpid.apache.org/proton/go/internal.Error"".autotmp_0110O(type.[1]interface {}Lqpid.apache.org/proton/go/reactor.l·2�
Vtype.qpid.apache.org/proton/go/reactor.Link"".ltype.*"".link"���
�!��"(�
!.�
;.OTgclocals·fbd5b7009fdd3864023723132632a4f4Tgclocals·bdc8dbf2e07519097eddde01a6360fd2�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�""".(*link).Source`DH�\$H��tH�kPH�l$H�kXH�l$É��0"".~r0type.string"".ltype.*"".link00�0Tgclocals·a08e9001cb8f9d822225de3b8e406515Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�""".(*link).Target`DH�\$H��tH�k`H�l$H�khH�l$��0"".~r0type.string"".ltype.*"".link00�0Tgc
 locals·a08e9001cb8f9d822225de3b8e406515Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�"".(*link).Name`DH�\$H��tH�k@H�l$H�kHH�l$É��0"".~r0type.string"".ltype.*"".link00�0Tgclocals·a08e9001cb8f9d822225de3b8e406515Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�&"".(*link).IsSender H�\$�k0@�l$� "".~r0type.bool"".ltype.*"".link�Tgclocals·06cab038d51064a089bda21fa03e00f7Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�*"".(*link).IsReceiver@6H�l$�]0��t�D$��D$
�� "".~r0type.bool"".ltype.*"".link  � Tgclocals·06cab038d51064a089bda21
 fa03e00f7Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�("".(*link).SetSource�
�
dH�%H;aw���H��H�\$ H�$�H�\$ H�$H�<$t#H�$PH�\$(H�\$H�\$0H�\$�H��É%��
- 0runtime.morestack_noctxtH2"".(*link).setPanicIfLink�
4runtime.writebarrierstring00"".stype.string"".ltype.*"".link0@/
0p�p
-#MTgclocals·d3486bc7ce1948dc22d7ad1c0be2887aTgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�("".(*link).SetTarget�
�
dH�%H;aw���H��H�\$ H�$�H�\$ H�$H�<$t#H�$`H�\$(H�\$H�\$0H�\$�H��É%��
- 0runtime.morestack_noctxtH2"".(*link).setPanicIfLink�
4runtime.writebarrierstring00"".stype.string"".ltype.*"".link0@/
0p�p
-#MTgclocals·d3486bc7ce1948dc22d7ad1c0be2887aTgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�$"".(*link).SetName�
�
dH�%H;aw���H��H�\$ H�$�H�\$ H�$H�<$t#H�$@H�\$(H�\$H�\$0H�\$�H��É%��
- 0runtime.morestack_noctxtH2"".(*link).setPanicIfLink�
4runtime.writebarrierstring00"".stype.string"".ltype.*"".link0@/
0p�p
-#MTgclocals·d3486bc7ce1948dc22d7ad1c0be2887aTgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�""".(*link).IsOpen H�\$�kp@�l$� "".~r0type.bool"".ltype.*"".link�Tgclocals·06cab038d51064a089bda21fa03e00f7Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�$"".(*link).Session��dH�%H;aw���H�� H�D$0H�D$8H�1�H9�tH�\$(H�k(H�l$8H�D$0H�� �H�H�$H�H�\$H�H�\$�H�D$�
- 0runtime.morestack_noctxt^<go.itab.*"".session."".Session�
 type.*"".session�
type."".Session�
<go.itab.*"".session."".Session�
 runtime.typ2Itab0@"".~r0type."".Session"".ltype.*"".link@7?
@>�

-��

-uTgclocals·a08e9001cb8f9d822225de3b8e406515Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�*"".(*link).Connection@&H�\$H�k(H�m0H�l$� "".~r0&type.*"".Connection"".ltype.*"".link  � Tgclocals·06cab038d51064a089bda21fa03e00f7Tgclocals·3280bececceccd33cb74587feedb1f9f�
/home/aconway/proton/proton-c/bindings/go/src/qpid.apache.org/proton/go/messaging/link.go�"".(*link).pump�
vdH�%H;aw���H��H�\$H�$�H�\

<TRUNCATED>

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org