Skip to content

Commit 846f354

Browse files
committed
Port log4j-flume-ng changes from 2.x
1 parent 909ac6b commit 846f354

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeAvroManager.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,6 @@ public static FlumeAvroManager getManager(
110110
if (batchSize <= 0) {
111111
batchSize = 1;
112112
}
113-
;
114113
final StringBuilder sb = new StringBuilder(name);
115114
sb.append(" FlumeAvro[");
116115
boolean first = true;
@@ -221,7 +220,7 @@ public void send(final Event event) {
221220
} else {
222221
int eventCount;
223222
BatchEvent batch = null;
224-
synchronized (batchEvent) {
223+
synchronized (this) {
225224
batchEvent.addEvent(event);
226225
eventCount = batchEvent.size();
227226
final long now = System.nanoTime();

log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEmbeddedManager.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public class FlumeEmbeddedManager extends AbstractFlumeManager {
3838

3939
private static final String IN_MEMORY = "InMemory";
4040

41-
private static final FlumeManagerFactory factory = new FlumeManagerFactory();
41+
private static final FlumeManagerFactory FACTORY = new FlumeManagerFactory();
4242

4343
private final EmbeddedAgent agent;
4444

@@ -78,11 +78,11 @@ public static FlumeEmbeddedManager getManager(
7878
throw new IllegalArgumentException("Cannot configure both Agents and Properties.");
7979
}
8080

81-
final String managerName = createManagerName(name, agents, properties);
82-
return getManager(managerName, factory, new FactoryData(name, agents, properties, batchSize, dataDir));
81+
final String extendedName = extendManagerName(name, agents, properties);
82+
return getManager(extendedName, FACTORY, new FactoryData(name, agents, properties, batchSize, dataDir));
8383
}
8484

85-
private static String createManagerName(final String name, final Agent[] agents, final Property[] properties) {
85+
private static String extendManagerName(final String name, final Agent[] agents, final Property[] properties) {
8686

8787
final StringBuilder sb = new StringBuilder();
8888
boolean first = true;

log4j-flume-ng/src/main/java/org/apache/logging/log4j/flume/appender/FlumeEvent.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -295,7 +295,7 @@ public long getTimeMillis() {
295295

296296
/**
297297
* {@inheritDoc}
298-
* @since 2.11.0
298+
* @since 2.11
299299
*/
300300
@Override
301301
public Instant getInstant() {

0 commit comments

Comments
 (0)