#405

Committed 16 Apr 2024 05:58AM UTC coverage: 0.0% (-88.9%) from 88.866%

Build # #405

Build Type

push

Committed by

Commit Message

add encoding to fix coverage report

Run Details

0 of 5353 relevant lines covered (0.0%)

0.0 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/jetcache-core/src/main/java/com/alicp/jetcache/external/MockRemoteCacheBuilder.java

package com.alicp.jetcache.external;

import com.alicp.jetcache.CacheManager;
import com.alicp.jetcache.CacheResult;
import com.alicp.jetcache.support.BroadcastManager;
import com.alicp.jetcache.support.CacheMessage;

/**
 * Created on 2016/10/20.
 *
 * @author huangli
 */
public class MockRemoteCacheBuilder<T extends ExternalCacheBuilder<T>> extends ExternalCacheBuilder<T> {

    private static boolean subscribeStart;
    private static CacheMessage lastPublishMessage;

    public static class MockRemoteCacheBuilderImpl extends MockRemoteCacheBuilder<MockRemoteCacheBuilderImpl> {
    }

    public static MockRemoteCacheBuilderImpl createMockRemoteCacheBuilder() {
        return new MockRemoteCacheBuilderImpl();
    }

    @Override
    public MockRemoteCacheConfig getConfig() {
        if (config == null) {
            config = new MockRemoteCacheConfig();
        }
        return (MockRemoteCacheConfig) config;
    }

    @Override
    public boolean supportBroadcast() {
        return true;
    }

    @Override
    public BroadcastManager createBroadcastManager(CacheManager cacheManager) {
        return new BroadcastManager(cacheManager) {
            @Override
            public CacheResult publish(CacheMessage cacheMessage) {
                lastPublishMessage = cacheMessage;
                return CacheResult.SUCCESS_WITHOUT_MSG;
            }

            @Override
            public void startSubscribe() {
                subscribeStart = true;
            }
        };
    }

    public MockRemoteCacheBuilder() {
        this.setKeyPrefix("DEFAULT_PREFIX");
        buildFunc((c) -> new MockRemoteCache((MockRemoteCacheConfig) c));
    }

    public T limit(int limit) {
        getConfig().setLimit(limit);
        return self();
    }

    public void setLimit(int limit) {
        getConfig().setLimit(limit);
    }

    public static boolean isSubscribeStart() {
        return subscribeStart;
    }

    public static CacheMessage getLastPublishMessage() {
        return lastPublishMessage;
    }

    public static void reset() {
        subscribeStart = false;
        lastPublishMessage = null;
    }
}

1	package com.alicp.jetcache.external;
2
3	import com.alicp.jetcache.CacheManager;
4	import com.alicp.jetcache.CacheResult;
5	import com.alicp.jetcache.support.BroadcastManager;
6	import com.alicp.jetcache.support.CacheMessage;
7
8	/**
9	* Created on 2016/10/20.
10	*
11	* @author huangli
12	*/
13	public class MockRemoteCacheBuilder<T extends ExternalCacheBuilder<T>> extends ExternalCacheBuilder<T> {
14
15	private static boolean subscribeStart;
16	private static CacheMessage lastPublishMessage;
17
18	public static class MockRemoteCacheBuilderImpl extends MockRemoteCacheBuilder<MockRemoteCacheBuilderImpl> {	×
19	}
20
21	public static MockRemoteCacheBuilderImpl createMockRemoteCacheBuilder() {
22	return new MockRemoteCacheBuilderImpl();	×
23	}
24
25	@Override
26	public MockRemoteCacheConfig getConfig() {
27	if (config == null) {	×
28	config = new MockRemoteCacheConfig();	×
29	}
30	return (MockRemoteCacheConfig) config;	×
31	}
32
33	@Override
34	public boolean supportBroadcast() {
35	return true;	×
36	}
37
38	@Override
39	public BroadcastManager createBroadcastManager(CacheManager cacheManager) {
40	return new BroadcastManager(cacheManager) {	×
41	@Override
42	public CacheResult publish(CacheMessage cacheMessage) {
43	lastPublishMessage = cacheMessage;	×
44	return CacheResult.SUCCESS_WITHOUT_MSG;	×
45	}
46
47	@Override
48	public void startSubscribe() {
49	subscribeStart = true;	×
50	}	×
51	};
52	}
53
54	public MockRemoteCacheBuilder() {	×
55	this.setKeyPrefix("DEFAULT_PREFIX");	×
56	buildFunc((c) -> new MockRemoteCache((MockRemoteCacheConfig) c));	×
57	}	×
58
59	public T limit(int limit) {
60	getConfig().setLimit(limit);	×
61	return self();	×
62	}
63
64	public void setLimit(int limit) {
65	getConfig().setLimit(limit);	×
66	}	×
67
68	public static boolean isSubscribeStart() {
69	return subscribeStart;	×
70	}
71
72	public static CacheMessage getLastPublishMessage() {
73	return lastPublishMessage;	×
74	}
75
76	public static void reset() {
77	subscribeStart = false;	×
78	lastPublishMessage = null;	×
79	}	×
80	}

alibaba / jetcache / #405

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous