Skip to content

Commit

Permalink
Add getters to RSocketMessageHandler
Browse files Browse the repository at this point in the history
  • Loading branch information
rstoyanchev committed Jul 8, 2019
1 parent 2f77541 commit 7b1a6eb
Showing 1 changed file with 26 additions and 0 deletions.
Original file line number Original file line Diff line number Diff line change
Expand Up @@ -148,6 +148,15 @@ public void setMetadataExtractor(MetadataExtractor extractor) {
this.metadataExtractor = extractor; this.metadataExtractor = extractor;
} }


/**
* Return the configured {@link #setMetadataExtractor MetadataExtractor}.
* This may be {@code null} before {@link #afterPropertiesSet()}.
*/
@Nullable
public MetadataExtractor getMetadataExtractor() {
return this.metadataExtractor;
}

/** /**
* Configure the default content type to use for data payloads if the * Configure the default content type to use for data payloads if the
* {@code SETUP} frame did not specify one. * {@code SETUP} frame did not specify one.
Expand All @@ -158,6 +167,15 @@ public void setDefaultDataMimeType(@Nullable MimeType mimeType) {
this.defaultDataMimeType = mimeType; this.defaultDataMimeType = mimeType;
} }


/**
* Return the configured
* {@link #setDefaultDataMimeType defaultDataMimeType}, or {@code null}.
*/
@Nullable
public MimeType getDefaultDataMimeType() {
return this.defaultDataMimeType;
}

/** /**
* Configure the default {@code MimeType} for payload data if the * Configure the default {@code MimeType} for payload data if the
* {@code SETUP} frame did not specify one. * {@code SETUP} frame did not specify one.
Expand All @@ -169,6 +187,14 @@ public void setDefaultMetadataMimeType(MimeType mimeType) {
this.defaultMetadataMimeType = mimeType; this.defaultMetadataMimeType = mimeType;
} }


/**
* Return the configured
* {@link #setDefaultMetadataMimeType defaultMetadataMimeType}.
*/
public MimeType getDefaultMetadataMimeType() {
return this.defaultMetadataMimeType;
}



@Override @Override
public void afterPropertiesSet() { public void afterPropertiesSet() {
Expand Down

0 comments on commit 7b1a6eb

Please sign in to comment.