24.7. 예

키/값을 이름이 지정된 캐시에 배치합니다.

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.PUT) (1)
    .setHeader(InfinispanConstants.KEY).constant("123") (2)
    .to("infinispan:myCacheName&cacheContainer=#cacheContainer"); (3)

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.PUT) (1)
    .setHeader(InfinispanConstants.KEY).constant("123") (2)
    .to("infinispan:myCacheName&cacheContainer=#cacheContainer"); (3)

Copy to Clipboard

Toggle word wrap

여기서,

1 - 수행할 작업 설정
2 - 캐시에서 요소를 식별하는 데 사용되는 키 설정

3 - 레지스트리에서 구성된 캐시 관리자 cacheContainer 를 사용하여 요소를 myCacheName이라는 캐시에 배치

항목이 만료되고 캐시에서 제거되기 전에 수명 및/또는 유휴 시간을 구성할 수 있습니다. 예를 들면 다음과 같습니다.

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.GET)
    .setHeader(InfinispanConstants.KEY).constant("123")
    .setHeader(InfinispanConstants.LIFESPAN_TIME).constant(100L) (1)
    .setHeader(InfinispanConstants.LIFESPAN_TIME_UNIT.constant(TimeUnit.MILLISECONDS.toString()) (2)
    .to("infinispan:myCacheName");

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION).constant(InfinispanOperation.GET)
    .setHeader(InfinispanConstants.KEY).constant("123")
    .setHeader(InfinispanConstants.LIFESPAN_TIME).constant(100L) (1)
    .setHeader(InfinispanConstants.LIFESPAN_TIME_UNIT.constant(TimeUnit.MILLISECONDS.toString()) (2)
    .to("infinispan:myCacheName");

Copy to Clipboard

Toggle word wrap

여기서,

1 - 항목의 수명을 설정합니다.
2 - 수명 기간의 시간 단위 설정

쿼리

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION, InfinispanConstants.QUERY)
    .setHeader(InfinispanConstants.QUERY_BUILDER, new InfinispanQueryBuilder() {
        @Override
        public Query build(QueryFactory<Query> qf) {
            return qf.from(User.class).having("name").like("%abc%").build();
        }
    })
    .to("infinispan:myCacheName?cacheContainer=#cacheManager") ;

from("direct:start")
    .setHeader(InfinispanConstants.OPERATION, InfinispanConstants.QUERY)
    .setHeader(InfinispanConstants.QUERY_BUILDER, new InfinispanQueryBuilder() {
        @Override
        public Query build(QueryFactory<Query> qf) {
            return qf.from(User.class).having("name").like("%abc%").build();
        }
    })
    .to("infinispan:myCacheName?cacheContainer=#cacheManager") ;

Copy to Clipboard

Toggle word wrap

참고

도메인 오브젝트에 대한 .proto 설명자는 원격 Data Grid 서버에 등록해야 합니다. 공식 Infinispan 설명서의 원격 쿼리 예제 를 참조하십시오.

사용자 정의 청취자

from("infinispan://?cacheContainer=#cacheManager&customListener=#myCustomListener")
  .to("mock:result");

from("infinispan://?cacheContainer=#cacheManager&customListener=#myCustomListener")
  .to("mock:result");

Copy to Clipboard

Toggle word wrap

myCustomListener 인스턴스가 있어야 하며 Camel은 레지스트리에서 검색할 수 있어야 합니다. 사용자는 org.apache.camel.component.infinispan.remote.InfinispanRemoteCustomListener 클래스를 확장하고 패키지 org.infinispan.client.hotrod.annotation 에서 찾을 수 있는 @ClientListener 로 결과 클래스에 주석을 달 것을 권장합니다.

맨 위로 이동

24.7. 예

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat 소개

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links