Sender (Aeron Message Transport)

java.lang.Object
- io.aeron.driver.Sender

All Implemented Interfaces:

org.agrona.concurrent.Agent
```
public class Sender
extends java.lang.Object
implements org.agrona.concurrent.Agent
```
Agent that iterates over NetworkPublications for sending them to registered subscribers.

Field Summary

Fields
Modifier and Type	Field and Description
`protected long`	`controlPollDeadlineNs`
`protected int`	`dutyCycleCounter`
`protected long`	`p1`
`protected long`	`p10`
`protected long`	`p11`
`protected long`	`p12`
`protected long`	`p13`
`protected long`	`p14`
`protected long`	`p15`
`protected long`	`p16`
`protected long`	`p17`
`protected long`	`p18`
`protected long`	`p19`
`protected long`	`p2`
`protected long`	`p20`
`protected long`	`p21`
`protected long`	`p22`
`protected long`	`p23`
`protected long`	`p24`
`protected long`	`p25`
`protected long`	`p26`
`protected long`	`p27`
`protected long`	`p28`
`protected long`	`p29`
`protected long`	`p3`
`protected long`	`p30`
`protected long`	`p4`
`protected long`	`p5`
`protected long`	`p6`
`protected long`	`p7`
`protected long`	`p8`
`protected long`	`p9`
`protected int`	`roundRobinIndex`

Constructor Summary

Constructors
Constructor and Description

Sender(MediaDriver.Context ctx)

Constructors
Constructor and Description
`Sender(MediaDriver.Context ctx)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`int`	`doWork()`
`void`	`onAddDestination(SendChannelEndpoint channelEndpoint, java.net.InetSocketAddress address)`
`void`	`onClose()`
`void`	`onCloseSendChannelEndpoint(SendChannelEndpoint channelEndpoint)`
`void`	`onNewNetworkPublication(NetworkPublication publication)`
`void`	`onRegisterSendChannelEndpoint(SendChannelEndpoint channelEndpoint)`
`void`	`onRemoveDestination(SendChannelEndpoint channelEndpoint, java.net.InetSocketAddress address)`
`void`	`onRemoveNetworkPublication(NetworkPublication publication)`
`java.lang.String`	`roleName()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.agrona.concurrent.Agent
onStart

Field Detail

p16
```
protected long p16
```

p17
```
protected long p17
```

p18
```
protected long p18
```

p19
```
protected long p19
```

p20
```
protected long p20
```

p21
```
protected long p21
```

p22
```
protected long p22
```

p23
```
protected long p23
```

p24
```
protected long p24
```

p25
```
protected long p25
```

p26
```
protected long p26
```

p27
```
protected long p27
```

p28
```
protected long p28
```

p29
```
protected long p29
```

p30
```
protected long p30
```

controlPollDeadlineNs
```
protected long controlPollDeadlineNs
```

dutyCycleCounter
```
protected int dutyCycleCounter
```

roundRobinIndex
```
protected int roundRobinIndex
```

p1
```
protected long p1
```

p2
```
protected long p2
```

p3
```
protected long p3
```

p4
```
protected long p4
```

p5
```
protected long p5
```

p6
```
protected long p6
```

p7
```
protected long p7
```

p8
```
protected long p8
```

p9
```
protected long p9
```

p10
```
protected long p10
```

p11
```
protected long p11
```

p12
```
protected long p12
```

p13
```
protected long p13
```

p14
```
protected long p14
```

p15
```
protected long p15
```

Constructor Detail

Sender

public Sender(MediaDriver.Context ctx)

Method Detail

onClose
```
public void onClose()
```
Specified by:

onClose in interface org.agrona.concurrent.Agent

doWork
```
public int doWork()
```
Specified by:

doWork in interface org.agrona.concurrent.Agent

roleName
```
public java.lang.String roleName()
```
Specified by:

roleName in interface org.agrona.concurrent.Agent

onRegisterSendChannelEndpoint

public void onRegisterSendChannelEndpoint(SendChannelEndpoint channelEndpoint)

onCloseSendChannelEndpoint

public void onCloseSendChannelEndpoint(SendChannelEndpoint channelEndpoint)

onNewNetworkPublication

public void onNewNetworkPublication(NetworkPublication publication)

onRemoveNetworkPublication

public void onRemoveNetworkPublication(NetworkPublication publication)

onAddDestination

public void onAddDestination(SendChannelEndpoint channelEndpoint,
                             java.net.InetSocketAddress address)

onRemoveDestination

public void onRemoveDestination(SendChannelEndpoint channelEndpoint,
                                java.net.InetSocketAddress address)

Class Sender

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface org.agrona.concurrent.Agent

Field Detail

p16

p17

p18

p19

p20

p21

p22

p23

p24

p25

p26

p27

p28

p29

p30

controlPollDeadlineNs

dutyCycleCounter

roundRobinIndex

p1

p2

p3

p4

p5

p6

p7

p8

p9

p10

p11

p12

p13

p14

p15

Constructor Detail

Sender

Method Detail

onClose

doWork

roleName

onRegisterSendChannelEndpoint

onCloseSendChannelEndpoint

onNewNetworkPublication

onRemoveNetworkPublication

onAddDestination

onRemoveDestination